Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

correctable

package

Go to main page

Versions in this module

v0

v0.10.0

Nov 14, 2025

Changes in this version

+ type CorrectableRequest_builder struct

+ func (b0 CorrectableRequest_builder) Build() *CorrectableRequest

type CorrectableResponse

+ func (x *CorrectableResponse) SetLevel(v int32)

+ type CorrectableResponse_builder struct

+ Level int32

+ func (b0 CorrectableResponse_builder) Build() *CorrectableResponse

v0.9.0

Apr 7, 2025

v0.8.1

Mar 5, 2025

v0.8.0

Mar 5, 2025

Changes in this version

+ type CorrectableTestClient interface

+ Correctable func(ctx context.Context, in *CorrectableRequest) *CorrectableCorrectableResponse

+ CorrectableStream func(ctx context.Context, in *CorrectableRequest) *CorrectableStreamCorrectableResponse

+ type CorrectableTestServer interface

+ Correctable func(ctx gorums.ServerCtx, request *CorrectableRequest) (response *CorrectableResponse, err error)

+ CorrectableStream func(ctx gorums.ServerCtx, request *CorrectableRequest, ...) error

v0.7.0

Jan 6, 2022

Changes in this version

type Configuration

+ func ConfigurationFromRaw(rawCfg gorums.RawConfiguration, qspec QuorumSpec) *Configuration

v0.6.1

Dec 18, 2021

v0.6.0

Dec 13, 2021

Changes in this version

+ var File_correctable_correctable_proto protoreflect.FileDescriptor

+ func RegisterCorrectableTestServer(srv *gorums.Server, impl CorrectableTest)

+ type Configuration struct

+ func (c *Configuration) Correctable(ctx context.Context, in *CorrectableRequest) *CorrectableCorrectableResponse

+ func (c *Configuration) CorrectableStream(ctx context.Context, in *CorrectableRequest) *CorrectableStreamCorrectableResponse

+ func (c *Configuration) Nodes() []*Node

+ func (c Configuration) And(d *Configuration) gorums.NodeListOption

+ func (c Configuration) Except(rm *Configuration) gorums.NodeListOption

+ type CorrectableCorrectableResponse struct

+ func (c *CorrectableCorrectableResponse) Get() (*CorrectableResponse, int, error)

+ type CorrectableRequest struct

+ func (*CorrectableRequest) Descriptor() ([]byte, []int)

+ func (*CorrectableRequest) ProtoMessage()

+ func (x *CorrectableRequest) ProtoReflect() protoreflect.Message

+ func (x *CorrectableRequest) Reset()

+ func (x *CorrectableRequest) String() string

+ type CorrectableResponse struct

+ Level int32

+ func (*CorrectableResponse) Descriptor() ([]byte, []int)

+ func (*CorrectableResponse) ProtoMessage()

+ func (x *CorrectableResponse) GetLevel() int32

+ func (x *CorrectableResponse) ProtoReflect() protoreflect.Message

+ func (x *CorrectableResponse) Reset()

+ func (x *CorrectableResponse) String() string

+ type CorrectableStreamCorrectableResponse struct

+ func (c *CorrectableStreamCorrectableResponse) Get() (*CorrectableResponse, int, error)

+ type CorrectableTest interface

+ Correctable func(ctx gorums.ServerCtx, request *CorrectableRequest) (response *CorrectableResponse, err error)

+ CorrectableStream func(ctx gorums.ServerCtx, request *CorrectableRequest, ...) error

+ type Manager struct

+ func NewManager(opts ...gorums.ManagerOption) (mgr *Manager)

+ func (m *Manager) NewConfiguration(opts ...gorums.ConfigOption) (c *Configuration, err error)

+ func (m *Manager) Nodes() []*Node

+ type Node struct

+ type QuorumSpec interface

+ CorrectableQF func(in *CorrectableRequest, replies map[uint32]*CorrectableResponse) (*CorrectableResponse, int, bool)

+ CorrectableStreamQF func(in *CorrectableRequest, replies map[uint32]*CorrectableResponse) (*CorrectableResponse, int, bool)