dev

package

Go to main page

Versions in this module

v0

v0.11.0

Jan 4, 2026

Changes in this version

+ func Multicast(ctx *gorums.ConfigContext, in *Request, opts ...gorums.CallOption) error

+ func Multicast2(ctx *gorums.ConfigContext, in *Request, opts ...gorums.CallOption) error

+ func Multicast3(ctx *gorums.ConfigContext, in *Request, opts ...gorums.CallOption) error

+ func Multicast4(ctx *gorums.ConfigContext, in *emptypb.Empty, opts ...gorums.CallOption) error

+ func QuorumCall(ctx *gorums.ConfigContext, in *Request, opts ...gorums.CallOption) *gorums.Responses[*Response]

+ func QuorumCallEmpty(ctx *gorums.ConfigContext, in *emptypb.Empty, opts ...gorums.CallOption) *gorums.Responses[*Response]

+ func QuorumCallEmpty2(ctx *gorums.ConfigContext, in *Request, opts ...gorums.CallOption) *gorums.Responses[*emptypb.Empty]

+ func QuorumCallStream(ctx *gorums.ConfigContext, in *Request, opts ...gorums.CallOption) *gorums.Responses[*Response]

+ func QuorumCallStreamWithEmpty(ctx *gorums.ConfigContext, in *Request, opts ...gorums.CallOption) *gorums.Responses[*emptypb.Empty]

+ func QuorumCallStreamWithEmpty2(ctx *gorums.ConfigContext, in *emptypb.Empty, opts ...gorums.CallOption) *gorums.Responses[*Response]

+ func Unicast(ctx *gorums.NodeContext, in *Request, opts ...gorums.CallOption) error

+ func Unicast2(ctx *gorums.NodeContext, in *Request, opts ...gorums.CallOption) error

type Configuration

+ func NewConfiguration(mgr *Manager, opt gorums.NodeListOption) (Configuration, error)

type Response

+ func GRPCCall(ctx *gorums.NodeContext, in *Request) (resp *Response, err error)

type ZorumsServiceServer

+ QuorumCallStream func(ctx gorums.ServerCtx, request *Request, send func(response *Response) error) error

+ QuorumCallStreamWithEmpty func(ctx gorums.ServerCtx, request *Request, ...) error

+ QuorumCallStreamWithEmpty2 func(ctx gorums.ServerCtx, request *emptypb.Empty, ...) error

v0.10.0

Nov 14, 2025

v0.9.0

Apr 7, 2025

v0.8.1

Mar 5, 2025

v0.8.0

Mar 5, 2025

Changes in this version

type MyResponse

+ func (x *MyResponse) SetValue(v string)

+ type MyResponse_builder struct

+ Value string

+ func (b0 MyResponse_builder) Build() *MyResponse

type Request

+ func (x *Request) SetValue(v string)

+ type Request_builder struct

+ Value string

+ func (b0 Request_builder) Build() *Request

type Response

+ func (x *Response) SetResult(v int64)

+ type Response_builder struct

+ Result int64

+ func (b0 Response_builder) Build() *Response

type ZorumsServiceClient

+ QuorumCallAsync func(ctx context.Context, in *Request) *AsyncResponse

+ QuorumCallAsync2 func(ctx context.Context, in *Request) *AsyncResponse

+ QuorumCallAsyncCombo func(ctx context.Context, in *Request, f func(*Request, uint32) *Request) *AsyncMyResponse

+ QuorumCallAsyncCustomReturnType func(ctx context.Context, in *Request) *AsyncMyResponse

+ QuorumCallAsyncEmpty func(ctx context.Context, in *Request) *AsyncEmpty

+ QuorumCallAsyncEmpty2 func(ctx context.Context, in *emptypb.Empty) *AsyncResponse

+ QuorumCallAsyncPerNodeArg func(ctx context.Context, in *Request, f func(*Request, uint32) *Request) *AsyncResponse

+ type ZorumsServiceNodeClient interface

+ GRPCCall func(ctx context.Context, in *Request) (resp *Response, err error)

+ Unicast func(ctx context.Context, in *Request, opts ...gorums.CallOption)

+ Unicast2 func(ctx context.Context, in *Request, opts ...gorums.CallOption)

type ZorumsServiceServer

+ QuorumCallAsync func(ctx gorums.ServerCtx, request *Request) (response *Response, err error)

+ QuorumCallAsync2 func(ctx gorums.ServerCtx, request *Request) (response *Response, err error)

+ QuorumCallAsyncCombo func(ctx gorums.ServerCtx, request *Request) (response *Response, err error)

+ QuorumCallAsyncCustomReturnType func(ctx gorums.ServerCtx, request *Request) (response *Response, err error)

+ QuorumCallAsyncEmpty func(ctx gorums.ServerCtx, request *Request) (response *emptypb.Empty, err error)

+ QuorumCallAsyncEmpty2 func(ctx gorums.ServerCtx, request *emptypb.Empty) (response *Response, err error)

+ QuorumCallAsyncPerNodeArg func(ctx gorums.ServerCtx, request *Request) (response *Response, err 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

v0.5.0

May 10, 2021

v0.4.0

Mar 27, 2021

Changes in this version

type Configuration

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

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

v0.3.0

Feb 26, 2021

Changes in this version

+ type AsyncEmpty struct

+ func (f *AsyncEmpty) Get() (*emptypb.Empty, error)

+ type AsyncMyResponse struct

+ func (f *AsyncMyResponse) Get() (*MyResponse, error)

+ type AsyncResponse struct

+ func (f *AsyncResponse) Get() (*Response, error)

type Configuration

+ func (c *Configuration) QuorumCallAsync(ctx context.Context, in *Request) *AsyncResponse

+ func (c *Configuration) QuorumCallAsync2(ctx context.Context, in *Request) *AsyncResponse

+ func (c *Configuration) QuorumCallAsyncCombo(ctx context.Context, in *Request, f func(*Request, uint32) *Request) *AsyncMyResponse

+ func (c *Configuration) QuorumCallAsyncCustomReturnType(ctx context.Context, in *Request) *AsyncMyResponse

+ func (c *Configuration) QuorumCallAsyncEmpty(ctx context.Context, in *Request) *AsyncEmpty

+ func (c *Configuration) QuorumCallAsyncEmpty2(ctx context.Context, in *emptypb.Empty) *AsyncResponse

+ func (c *Configuration) QuorumCallAsyncPerNodeArg(ctx context.Context, in *Request, f func(*Request, uint32) *Request) *AsyncResponse

type Node

+ func (n *Node) GRPCCall(ctx context.Context, in *Request) (resp *Response, err error)

type QuorumSpec

+ QuorumCallAsync2QF func(in *Request, replies map[uint32]*Response) (*Response, bool)

+ QuorumCallAsyncComboQF func(in *Request, replies map[uint32]*Response) (*MyResponse, bool)

+ QuorumCallAsyncCustomReturnTypeQF func(in *Request, replies map[uint32]*Response) (*MyResponse, bool)

+ QuorumCallAsyncEmpty2QF func(in *emptypb.Empty, replies map[uint32]*Response) (*Response, bool)

+ QuorumCallAsyncEmptyQF func(in *Request, replies map[uint32]*emptypb.Empty) (*emptypb.Empty, bool)

+ QuorumCallAsyncPerNodeArgQF func(in *Request, replies map[uint32]*Response) (*Response, bool)

+ QuorumCallAsyncQF func(in *Request, replies map[uint32]*Response) (*Response, bool)

type ZorumsService

+ Correctable func(context.Context, *Request, func(*Response, error))

+ CorrectableCombo func(context.Context, *Request, func(*Response, error))

+ CorrectableCustomReturnType func(context.Context, *Request, func(*Response, error))

+ CorrectableEmpty func(context.Context, *Request, func(*emptypb.Empty, error))

+ CorrectableEmpty2 func(context.Context, *emptypb.Empty, func(*Response, error))

+ CorrectablePerNodeArg func(context.Context, *Request, func(*Response, error))

+ CorrectableStream func(context.Context, *Request, func(*Response, error))

+ CorrectableStreamCombo func(context.Context, *Request, func(*Response, error))

+ CorrectableStreamCustomReturnType func(context.Context, *Request, func(*Response, error))

+ CorrectableStreamEmpty func(context.Context, *Request, func(*emptypb.Empty, error))

+ CorrectableStreamEmpty2 func(context.Context, *emptypb.Empty, func(*Response, error))

+ CorrectableStreamPerNodeArg func(context.Context, *Request, func(*Response, error))

+ GRPCCall func(context.Context, *Request, func(*Response, error))

+ QuorumCall func(context.Context, *Request, func(*Response, error))

+ QuorumCallAsync func(context.Context, *Request, func(*Response, error))

+ QuorumCallAsync2 func(context.Context, *Request, func(*Response, error))

+ QuorumCallAsyncCombo func(context.Context, *Request, func(*Response, error))

+ QuorumCallAsyncCustomReturnType func(context.Context, *Request, func(*Response, error))

+ QuorumCallAsyncEmpty func(context.Context, *Request, func(*emptypb.Empty, error))

+ QuorumCallAsyncEmpty2 func(context.Context, *emptypb.Empty, func(*Response, error))

+ QuorumCallAsyncPerNodeArg func(context.Context, *Request, func(*Response, error))

+ QuorumCallCombo func(context.Context, *Request, func(*Response, error))

+ QuorumCallCustomReturnType func(context.Context, *Request, func(*Response, error))

+ QuorumCallEmpty func(context.Context, *emptypb.Empty, func(*Response, error))

+ QuorumCallEmpty2 func(context.Context, *Request, func(*emptypb.Empty, error))

+ QuorumCallPerNodeArg func(context.Context, *Request, func(*Response, error))

v0.2.2

Jul 20, 2020

v0.2.1

Jul 20, 2020

Changes in this version

type ManagerOption

+ func WithMetadata(md metadata.MD) ManagerOption

+ func WithNodeList(addrsList []string) ManagerOption

+ func WithNodeMap(idMap map[string]uint32) ManagerOption

+ func WithPerNodeMetadata(f func(uint32) metadata.MD) ManagerOption

v0.2.0

Jun 29, 2020

Changes in this version

+ const LevelNotSet

+ var Error = func(n1, n2 *Node) bool

+ var File_zorums_proto protoreflect.FileDescriptor

+ var ID = func(n1, n2 *Node) bool

+ var Latency = func(n1, n2 *Node) bool

+ var Port = func(n1, n2 *Node) bool

+ func Equal(a, b *Configuration) bool

+ func ManagerCreationError(err error) error

+ func RegisterZorumsServiceServer(s *grpc.Server, srv ZorumsServiceServer)

+ type ConfigNotFoundError uint32

+ func (e ConfigNotFoundError) Error() string

+ type Configuration struct

+ func NewConfig(addrs []string, qspec QuorumSpec, opts ...ManagerOption) (*Configuration, func(), error)

+ func (c *Configuration) Correctable(ctx context.Context, in *Request, opts ...grpc.CallOption) *CorrectableResponse

+ func (c *Configuration) CorrectableCombo(ctx context.Context, in *Request, f func(*Request, uint32) *Request, ...) *CorrectableMyResponse

+ func (c *Configuration) CorrectableCustomReturnType(ctx context.Context, in *Request, opts ...grpc.CallOption) *CorrectableMyResponse

+ func (c *Configuration) CorrectableEmpty(ctx context.Context, in *Request, opts ...grpc.CallOption) *CorrectableEmpty

+ func (c *Configuration) CorrectableEmpty2(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) *CorrectableResponse

+ func (c *Configuration) CorrectablePerNodeArg(ctx context.Context, in *Request, f func(*Request, uint32) *Request, ...) *CorrectableResponse

+ func (c *Configuration) CorrectableStream(ctx context.Context, in *Request, opts ...grpc.CallOption) *CorrectableStreamResponse

+ func (c *Configuration) CorrectableStreamCombo(ctx context.Context, in *Request, f func(*Request, uint32) *Request, ...) *CorrectableStreamMyResponse

+ func (c *Configuration) CorrectableStreamCustomReturnType(ctx context.Context, in *Request, opts ...grpc.CallOption) *CorrectableStreamMyResponse

+ func (c *Configuration) CorrectableStreamEmpty(ctx context.Context, in *Request, opts ...grpc.CallOption) *CorrectableStreamEmpty

+ func (c *Configuration) CorrectableStreamEmpty2(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) *CorrectableStreamResponse

+ func (c *Configuration) CorrectableStreamPerNodeArg(ctx context.Context, in *Request, f func(*Request, uint32) *Request, ...) *CorrectableStreamResponse

+ func (c *Configuration) ID() uint32

+ func (c *Configuration) Multicast(in *Request) error

+ func (c *Configuration) Multicast2(in *Request) error

+ func (c *Configuration) Multicast3(in *Request) error

+ func (c *Configuration) Multicast4(in *empty.Empty) error

+ func (c *Configuration) MulticastConcurrent(in *Request) error

+ func (c *Configuration) MulticastPerNodeArg(in *Request, f func(*Request, uint32) *Request) error

+ func (c *Configuration) NodeIDs() []uint32

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

+ func (c *Configuration) OrderingCombo(ctx context.Context, in *Request, f func(*Request, uint32) *Request) (resp *MyResponse, err error)

+ func (c *Configuration) OrderingConcurrent(ctx context.Context, in *Request) (resp *Response, err error)

+ func (c *Configuration) OrderingCustomReturnType(ctx context.Context, in *Request) (resp *MyResponse, err error)

+ func (c *Configuration) OrderingFuture(ctx context.Context, in *Request) *FutureResponse

+ func (c *Configuration) OrderingFutureCombo(ctx context.Context, in *Request, f func(*Request, uint32) *Request) *FutureMyResponse

+ func (c *Configuration) OrderingFutureConcurrent(ctx context.Context, in *Request) *FutureResponse

+ func (c *Configuration) OrderingFutureCustomReturnType(ctx context.Context, in *Request) *FutureMyResponse

+ func (c *Configuration) OrderingFuturePerNodeArg(ctx context.Context, in *Request, f func(*Request, uint32) *Request) *FutureResponse

+ func (c *Configuration) OrderingPerNodeArg(ctx context.Context, in *Request, f func(*Request, uint32) *Request) (resp *Response, err error)

+ func (c *Configuration) OrderingQC(ctx context.Context, in *Request) (resp *Response, err error)

+ func (c *Configuration) QuorumCall(ctx context.Context, in *Request, opts ...grpc.CallOption) (resp *Response, err error)

+ func (c *Configuration) QuorumCallCombo(ctx context.Context, in *Request, f func(*Request, uint32) *Request, ...) (resp *MyResponse, err error)

+ func (c *Configuration) QuorumCallCustomReturnType(ctx context.Context, in *Request, opts ...grpc.CallOption) (resp *MyResponse, err error)

+ func (c *Configuration) QuorumCallEmpty(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (resp *Response, err error)

+ func (c *Configuration) QuorumCallEmpty2(ctx context.Context, in *Request, opts ...grpc.CallOption) (resp *empty.Empty, err error)

+ func (c *Configuration) QuorumCallFuture(ctx context.Context, in *Request, opts ...grpc.CallOption) *FutureResponse

+ func (c *Configuration) QuorumCallFuture2(ctx context.Context, in *Request, opts ...grpc.CallOption) *FutureResponse

+ func (c *Configuration) QuorumCallFutureCombo(ctx context.Context, in *Request, f func(*Request, uint32) *Request, ...) *FutureMyResponse

+ func (c *Configuration) QuorumCallFutureCustomReturnType(ctx context.Context, in *Request, opts ...grpc.CallOption) *FutureMyResponse

+ func (c *Configuration) QuorumCallFutureEmpty(ctx context.Context, in *Request, opts ...grpc.CallOption) *FutureEmpty

+ func (c *Configuration) QuorumCallFutureEmpty2(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) *FutureResponse

+ func (c *Configuration) QuorumCallFuturePerNodeArg(ctx context.Context, in *Request, f func(*Request, uint32) *Request, ...) *FutureResponse

+ func (c *Configuration) QuorumCallPerNodeArg(ctx context.Context, in *Request, f func(*Request, uint32) *Request, ...) (resp *Response, err error)

+ func (c *Configuration) Size() int

+ func (c *Configuration) String() string

+ func (c *Configuration) SubError() <-chan GRPCError

+ type CorrectableEmpty struct

+ NodeIDs []uint32

+ func (c *CorrectableEmpty) Done() <-chan struct{}

+ func (c *CorrectableEmpty) Get() (*empty.Empty, int, error)

+ func (c *CorrectableEmpty) Watch(level int) <-chan struct{}

+ type CorrectableMyResponse struct

+ NodeIDs []uint32

+ func (c *CorrectableMyResponse) Done() <-chan struct{}

+ func (c *CorrectableMyResponse) Get() (*MyResponse, int, error)

+ func (c *CorrectableMyResponse) Watch(level int) <-chan struct{}

+ type CorrectableResponse struct

+ NodeIDs []uint32

+ func (c *CorrectableResponse) Done() <-chan struct{}

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

+ func (c *CorrectableResponse) Watch(level int) <-chan struct{}

+ type CorrectableStreamEmpty struct

+ NodeIDs []uint32

+ func (c *CorrectableStreamEmpty) Done() <-chan struct{}

+ func (c *CorrectableStreamEmpty) Get() (*empty.Empty, int, error)

+ func (c *CorrectableStreamEmpty) Watch(level int) <-chan struct{}

+ type CorrectableStreamMyResponse struct

+ NodeIDs []uint32

+ func (c *CorrectableStreamMyResponse) Done() <-chan struct{}

+ func (c *CorrectableStreamMyResponse) Get() (*MyResponse, int, error)

+ func (c *CorrectableStreamMyResponse) Watch(level int) <-chan struct{}

+ type CorrectableStreamResponse struct

+ NodeIDs []uint32

+ func (c *CorrectableStreamResponse) Done() <-chan struct{}

+ func (c *CorrectableStreamResponse) Get() (*Response, int, error)

+ func (c *CorrectableStreamResponse) Watch(level int) <-chan struct{}

+ type FutureEmpty struct

+ NodeIDs []uint32

+ func (f *FutureEmpty) Done() bool

+ func (f *FutureEmpty) Get() (*empty.Empty, error)

+ type FutureMyResponse struct

+ NodeIDs []uint32

+ func (f *FutureMyResponse) Done() bool

+ func (f *FutureMyResponse) Get() (*MyResponse, error)

+ type FutureResponse struct

+ NodeIDs []uint32

+ func (f *FutureResponse) Done() bool

+ func (f *FutureResponse) Get() (*Response, error)

+ type GRPCError struct

+ Cause error

+ NodeID uint32

+ func (e GRPCError) Error() string

+ type GorumsServer struct

+ func NewGorumsServer(opts ...ServerOption) *GorumsServer

+ func (s *GorumsServer) GracefulStop()

+ func (s *GorumsServer) RegisterZorumsServiceServer(srv ZorumsService)

+ func (s *GorumsServer) Serve(listener net.Listener) error

+ func (s *GorumsServer) Stop()

+ type IllegalConfigError string

+ func (e IllegalConfigError) Error() string

+ type Manager struct

+ func NewManager(nodeAddrs []string, opts ...ManagerOption) (*Manager, error)

+ func (m *Manager) AddNode(addr string) error

+ func (m *Manager) Close()

+ func (m *Manager) Configuration(id uint32) (config *Configuration, found bool)

+ func (m *Manager) ConfigurationIDs() []uint32

+ func (m *Manager) Configurations() []*Configuration

+ func (m *Manager) NewConfiguration(ids []uint32, qspec QuorumSpec) (*Configuration, error)

+ func (m *Manager) Node(id uint32) (node *Node, found bool)

+ func (m *Manager) NodeIDs() []uint32

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

+ func (m *Manager) Size() (nodes, configs int)

+ type ManagerOption func(*managerOptions)

+ func WithBackoff(backoff backoff.Config) ManagerOption

+ func WithDialTimeout(timeout time.Duration) ManagerOption

+ func WithGrpcDialOptions(opts ...grpc.DialOption) ManagerOption

+ func WithLogger(logger *log.Logger) ManagerOption

+ func WithNoConnect() ManagerOption

+ func WithSendBufferSize(size uint) ManagerOption

+ func WithTracing() ManagerOption

+ type MultiSorter struct

+ func OrderedBy(less ...lessFunc) *MultiSorter

+ func (ms *MultiSorter) Len() int

+ func (ms *MultiSorter) Less(i, j int) bool

+ func (ms *MultiSorter) Sort(nodes []*Node)

+ func (ms *MultiSorter) Swap(i, j int)

+ type MyResponse struct

+ Value string

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

+ func (*MyResponse) ProtoMessage()

+ func (x *MyResponse) GetValue() string

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

+ func (x *MyResponse) Reset()

+ func (x *MyResponse) String() string

+ type Node struct

+ func (n *Node) Address() string

+ func (n *Node) Correctable(ctx context.Context, in *Request, replyChan chan<- internalResponse)

+ func (n *Node) CorrectableCombo(ctx context.Context, in *Request, replyChan chan<- internalResponse)

+ func (n *Node) CorrectableCustomReturnType(ctx context.Context, in *Request, replyChan chan<- internalResponse)

+ func (n *Node) CorrectableEmpty(ctx context.Context, in *Request, replyChan chan<- internalEmpty)

+ func (n *Node) CorrectableEmpty2(ctx context.Context, in *empty.Empty, replyChan chan<- internalResponse)

+ func (n *Node) CorrectablePerNodeArg(ctx context.Context, in *Request, replyChan chan<- internalResponse)

+ func (n *Node) CorrectableStream(ctx context.Context, in *Request, replyChan chan<- internalResponse)

+ func (n *Node) CorrectableStreamCombo(ctx context.Context, in *Request, replyChan chan<- internalResponse)

+ func (n *Node) CorrectableStreamCustomReturnType(ctx context.Context, in *Request, replyChan chan<- internalResponse)

+ func (n *Node) CorrectableStreamEmpty(ctx context.Context, in *Request, replyChan chan<- internalEmpty)

+ func (n *Node) CorrectableStreamEmpty2(ctx context.Context, in *empty.Empty, replyChan chan<- internalResponse)

+ func (n *Node) CorrectableStreamPerNodeArg(ctx context.Context, in *Request, replyChan chan<- internalResponse)

+ func (n *Node) FullString() string

+ func (n *Node) ID() uint32

+ func (n *Node) LastErr() error

+ func (n *Node) Latency() time.Duration

+ func (n *Node) OrderingUnaryRPC(ctx context.Context, in *Request, opts ...grpc.CallOption) (resp *Response, err error)

+ func (n *Node) OrderingUnaryRPCConcurrent(ctx context.Context, in *Request, opts ...grpc.CallOption) (resp *Response, err error)

+ func (n *Node) Port() string

+ func (n *Node) QuorumCall(ctx context.Context, in *Request, replyChan chan<- internalResponse)

+ func (n *Node) QuorumCallCombo(ctx context.Context, in *Request, replyChan chan<- internalResponse)

+ func (n *Node) QuorumCallCustomReturnType(ctx context.Context, in *Request, replyChan chan<- internalResponse)

+ func (n *Node) QuorumCallEmpty(ctx context.Context, in *empty.Empty, replyChan chan<- internalResponse)

+ func (n *Node) QuorumCallEmpty2(ctx context.Context, in *Request, replyChan chan<- internalEmpty)

+ func (n *Node) QuorumCallFuture(ctx context.Context, in *Request, replyChan chan<- internalResponse)

+ func (n *Node) QuorumCallFuture2(ctx context.Context, in *Request, replyChan chan<- internalResponse)

+ func (n *Node) QuorumCallFutureCombo(ctx context.Context, in *Request, replyChan chan<- internalResponse)

+ func (n *Node) QuorumCallFutureCustomReturnType(ctx context.Context, in *Request, replyChan chan<- internalResponse)

+ func (n *Node) QuorumCallFutureEmpty(ctx context.Context, in *Request, replyChan chan<- internalEmpty)

+ func (n *Node) QuorumCallFutureEmpty2(ctx context.Context, in *empty.Empty, replyChan chan<- internalResponse)

+ func (n *Node) QuorumCallFuturePerNodeArg(ctx context.Context, in *Request, replyChan chan<- internalResponse)

+ func (n *Node) QuorumCallPerNodeArg(ctx context.Context, in *Request, replyChan chan<- internalResponse)

+ func (n *Node) String() string

+ func (n *Node) Unicast(in *Request) error

+ func (n *Node) Unicast2(in *Request) error

+ func (n *Node) UnicastConcurrent(in *Request) error

+ type NodeNotFoundError uint32

+ func (e NodeNotFoundError) Error() string

+ type QuorumCallError struct

+ Errors []GRPCError

+ Reason string

+ ReplyCount int

+ func (e QuorumCallError) Error() string

+ type QuorumSpec interface

+ CorrectableComboQF func(in *Request, replies []*Response) (*MyResponse, int, bool)

+ CorrectableCustomReturnTypeQF func(in *Request, replies []*Response) (*MyResponse, int, bool)

+ CorrectableEmpty2QF func(in *empty.Empty, replies []*Response) (*Response, int, bool)

+ CorrectableEmptyQF func(in *Request, replies []*empty.Empty) (*empty.Empty, int, bool)

+ CorrectablePerNodeArgQF func(in *Request, replies []*Response) (*Response, int, bool)

+ CorrectableQF func(in *Request, replies []*Response) (*Response, int, bool)

+ CorrectableStreamComboQF func(in *Request, replies []*Response) (*MyResponse, int, bool)

+ CorrectableStreamCustomReturnTypeQF func(in *Request, replies []*Response) (*MyResponse, int, bool)

+ CorrectableStreamEmpty2QF func(in *empty.Empty, replies []*Response) (*Response, int, bool)

+ CorrectableStreamEmptyQF func(in *Request, replies []*empty.Empty) (*empty.Empty, int, bool)

+ CorrectableStreamPerNodeArgQF func(in *Request, replies []*Response) (*Response, int, bool)

+ CorrectableStreamQF func(in *Request, replies []*Response) (*Response, int, bool)

+ OrderingComboQF func(in *Request, replies []*Response) (*MyResponse, bool)

+ OrderingConcurrentQF func(in *Request, replies []*Response) (*Response, bool)

+ OrderingCustomReturnTypeQF func(in *Request, replies []*Response) (*MyResponse, bool)

+ OrderingFutureComboQF func(in *Request, replies []*Response) (*MyResponse, bool)

+ OrderingFutureConcurrentQF func(in *Request, replies []*Response) (*Response, bool)

+ OrderingFutureCustomReturnTypeQF func(in *Request, replies []*Response) (*MyResponse, bool)

+ OrderingFuturePerNodeArgQF func(in *Request, replies []*Response) (*Response, bool)

+ OrderingFutureQF func(in *Request, replies []*Response) (*Response, bool)

+ OrderingPerNodeArgQF func(in *Request, replies []*Response) (*Response, bool)

+ OrderingQCQF func(in *Request, replies []*Response) (*Response, bool)

+ QuorumCallComboQF func(in *Request, replies []*Response) (*MyResponse, bool)

+ QuorumCallCustomReturnTypeQF func(in *Request, replies []*Response) (*MyResponse, bool)

+ QuorumCallEmpty2QF func(in *Request, replies []*empty.Empty) (*empty.Empty, bool)

+ QuorumCallEmptyQF func(in *empty.Empty, replies []*Response) (*Response, bool)

+ QuorumCallFuture2QF func(in *Request, replies []*Response) (*Response, bool)

+ QuorumCallFutureComboQF func(in *Request, replies []*Response) (*MyResponse, bool)

+ QuorumCallFutureCustomReturnTypeQF func(in *Request, replies []*Response) (*MyResponse, bool)

+ QuorumCallFutureEmpty2QF func(in *empty.Empty, replies []*Response) (*Response, bool)

+ QuorumCallFutureEmptyQF func(in *Request, replies []*empty.Empty) (*empty.Empty, bool)

+ QuorumCallFuturePerNodeArgQF func(in *Request, replies []*Response) (*Response, bool)

+ QuorumCallFutureQF func(in *Request, replies []*Response) (*Response, bool)

+ QuorumCallPerNodeArgQF func(in *Request, replies []*Response) (*Response, bool)

+ QuorumCallQF func(in *Request, replies []*Response) (*Response, bool)

+ type Request struct

+ Value string

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

+ func (*Request) ProtoMessage()

+ func (x *Request) GetValue() string

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

+ func (x *Request) Reset()

+ func (x *Request) String() string

+ type Response struct

+ Result int64

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

+ func (*Response) ProtoMessage()

+ func (x *Response) GetResult() int64

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

+ func (x *Response) Reset()

+ func (x *Response) String() string

+ type ServerOption func(*serverOptions)

+ func WithGRPCServerOptions(opts ...grpc.ServerOption) ServerOption

+ func WithServerBufferSize(size uint) ServerOption

+ type UnimplementedZorumsServiceServer struct

+ func (*UnimplementedZorumsServiceServer) Correctable(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) CorrectableCombo(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) CorrectableCustomReturnType(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) CorrectableEmpty(context.Context, *Request) (*empty.Empty, error)

+ func (*UnimplementedZorumsServiceServer) CorrectableEmpty2(context.Context, *empty.Empty) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) CorrectablePerNodeArg(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) CorrectableStream(*Request, ZorumsService_CorrectableStreamServer) error

+ func (*UnimplementedZorumsServiceServer) CorrectableStreamCombo(*Request, ZorumsService_CorrectableStreamComboServer) error

+ func (*UnimplementedZorumsServiceServer) CorrectableStreamCustomReturnType(*Request, ZorumsService_CorrectableStreamCustomReturnTypeServer) error

+ func (*UnimplementedZorumsServiceServer) CorrectableStreamEmpty(*Request, ZorumsService_CorrectableStreamEmptyServer) error

+ func (*UnimplementedZorumsServiceServer) CorrectableStreamEmpty2(*empty.Empty, ZorumsService_CorrectableStreamEmpty2Server) error

+ func (*UnimplementedZorumsServiceServer) CorrectableStreamPerNodeArg(*Request, ZorumsService_CorrectableStreamPerNodeArgServer) error

+ func (*UnimplementedZorumsServiceServer) GRPCCall(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) Multicast(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) Multicast2(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) Multicast3(context.Context, *Request) (*empty.Empty, error)

+ func (*UnimplementedZorumsServiceServer) Multicast4(context.Context, *empty.Empty) (*empty.Empty, error)

+ func (*UnimplementedZorumsServiceServer) MulticastConcurrent(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) MulticastPerNodeArg(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) OrderingCombo(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) OrderingConcurrent(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) OrderingCustomReturnType(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) OrderingFuture(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) OrderingFutureCombo(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) OrderingFutureConcurrent(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) OrderingFutureCustomReturnType(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) OrderingFuturePerNodeArg(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) OrderingPerNodeArg(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) OrderingQC(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) OrderingUnaryRPC(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) OrderingUnaryRPCConcurrent(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) QuorumCall(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) QuorumCallCombo(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) QuorumCallCustomReturnType(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) QuorumCallEmpty(context.Context, *empty.Empty) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) QuorumCallEmpty2(context.Context, *Request) (*empty.Empty, error)

+ func (*UnimplementedZorumsServiceServer) QuorumCallFuture(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) QuorumCallFuture2(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) QuorumCallFutureCombo(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) QuorumCallFutureCustomReturnType(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) QuorumCallFutureEmpty(context.Context, *Request) (*empty.Empty, error)

+ func (*UnimplementedZorumsServiceServer) QuorumCallFutureEmpty2(context.Context, *empty.Empty) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) QuorumCallFuturePerNodeArg(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) QuorumCallPerNodeArg(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) Unicast(context.Context, *Request) (*Response, error)

+ func (*UnimplementedZorumsServiceServer) Unicast2(context.Context, *Request) (*empty.Empty, error)

+ func (*UnimplementedZorumsServiceServer) UnicastConcurrent(context.Context, *Request) (*empty.Empty, error)

+ type ZorumsService interface

+ Multicast func(*Request)

+ Multicast2 func(*Request)

+ Multicast3 func(*Request)

+ Multicast4 func(*empty.Empty)

+ MulticastConcurrent func(*Request)

+ MulticastPerNodeArg func(*Request)

+ OrderingCombo func(*Request) *Response

+ OrderingConcurrent func(*Request) *Response

+ OrderingCustomReturnType func(*Request) *Response

+ OrderingFuture func(*Request) *Response

+ OrderingFutureCombo func(*Request) *Response

+ OrderingFutureConcurrent func(*Request) *Response

+ OrderingFutureCustomReturnType func(*Request) *Response

+ OrderingFuturePerNodeArg func(*Request) *Response

+ OrderingPerNodeArg func(*Request) *Response

+ OrderingQC func(*Request) *Response

+ OrderingUnaryRPC func(*Request) *Response

+ OrderingUnaryRPCConcurrent func(*Request) *Response

+ Unicast func(*Request)

+ Unicast2 func(*Request)

+ UnicastConcurrent func(*Request)

+ type ZorumsServiceClient interface

+ Correctable func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ CorrectableCombo func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ CorrectableCustomReturnType func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ CorrectableEmpty func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*empty.Empty, error)

+ CorrectableEmpty2 func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Response, error)

+ CorrectablePerNodeArg func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ CorrectableStream func(ctx context.Context, in *Request, opts ...grpc.CallOption) (ZorumsService_CorrectableStreamClient, error)

+ CorrectableStreamCombo func(ctx context.Context, in *Request, opts ...grpc.CallOption) (ZorumsService_CorrectableStreamComboClient, error)

+ CorrectableStreamCustomReturnType func(ctx context.Context, in *Request, opts ...grpc.CallOption) (ZorumsService_CorrectableStreamCustomReturnTypeClient, error)

+ CorrectableStreamEmpty func(ctx context.Context, in *Request, opts ...grpc.CallOption) (ZorumsService_CorrectableStreamEmptyClient, error)

+ CorrectableStreamEmpty2 func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (ZorumsService_CorrectableStreamEmpty2Client, error)

+ CorrectableStreamPerNodeArg func(ctx context.Context, in *Request, opts ...grpc.CallOption) (ZorumsService_CorrectableStreamPerNodeArgClient, error)

+ GRPCCall func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ Multicast func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ Multicast2 func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ Multicast3 func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*empty.Empty, error)

+ Multicast4 func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)

+ MulticastConcurrent func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ MulticastPerNodeArg func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ OrderingCombo func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ OrderingConcurrent func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ OrderingCustomReturnType func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ OrderingFuture func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ OrderingFutureCombo func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ OrderingFutureConcurrent func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ OrderingFutureCustomReturnType func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ OrderingFuturePerNodeArg func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ OrderingPerNodeArg func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ OrderingQC func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ OrderingUnaryRPC func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ OrderingUnaryRPCConcurrent func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ QuorumCall func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ QuorumCallCombo func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ QuorumCallCustomReturnType func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ QuorumCallEmpty func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Response, error)

+ QuorumCallEmpty2 func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*empty.Empty, error)

+ QuorumCallFuture func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ QuorumCallFuture2 func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ QuorumCallFutureCombo func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ QuorumCallFutureCustomReturnType func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ QuorumCallFutureEmpty func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*empty.Empty, error)

+ QuorumCallFutureEmpty2 func(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*Response, error)

+ QuorumCallFuturePerNodeArg func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ QuorumCallPerNodeArg func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ Unicast func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*Response, error)

+ Unicast2 func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*empty.Empty, error)

+ UnicastConcurrent func(ctx context.Context, in *Request, opts ...grpc.CallOption) (*empty.Empty, error)

+ func NewZorumsServiceClient(cc grpc.ClientConnInterface) ZorumsServiceClient

+ type ZorumsServiceServer interface

+ Correctable func(context.Context, *Request) (*Response, error)

+ CorrectableCombo func(context.Context, *Request) (*Response, error)

+ CorrectableCustomReturnType func(context.Context, *Request) (*Response, error)

+ CorrectableEmpty func(context.Context, *Request) (*empty.Empty, error)

+ CorrectableEmpty2 func(context.Context, *empty.Empty) (*Response, error)

+ CorrectablePerNodeArg func(context.Context, *Request) (*Response, error)

+ CorrectableStream func(*Request, ZorumsService_CorrectableStreamServer) error

+ CorrectableStreamCombo func(*Request, ZorumsService_CorrectableStreamComboServer) error

+ CorrectableStreamCustomReturnType func(*Request, ZorumsService_CorrectableStreamCustomReturnTypeServer) error

+ CorrectableStreamEmpty func(*Request, ZorumsService_CorrectableStreamEmptyServer) error

+ CorrectableStreamEmpty2 func(*empty.Empty, ZorumsService_CorrectableStreamEmpty2Server) error

+ CorrectableStreamPerNodeArg func(*Request, ZorumsService_CorrectableStreamPerNodeArgServer) error

+ GRPCCall func(context.Context, *Request) (*Response, error)

+ Multicast func(context.Context, *Request) (*Response, error)

+ Multicast2 func(context.Context, *Request) (*Response, error)

+ Multicast3 func(context.Context, *Request) (*empty.Empty, error)

+ Multicast4 func(context.Context, *empty.Empty) (*empty.Empty, error)

+ MulticastConcurrent func(context.Context, *Request) (*Response, error)

+ MulticastPerNodeArg func(context.Context, *Request) (*Response, error)

+ OrderingCombo func(context.Context, *Request) (*Response, error)

+ OrderingConcurrent func(context.Context, *Request) (*Response, error)

+ OrderingCustomReturnType func(context.Context, *Request) (*Response, error)

+ OrderingFuture func(context.Context, *Request) (*Response, error)

+ OrderingFutureCombo func(context.Context, *Request) (*Response, error)

+ OrderingFutureConcurrent func(context.Context, *Request) (*Response, error)

+ OrderingFutureCustomReturnType func(context.Context, *Request) (*Response, error)

+ OrderingFuturePerNodeArg func(context.Context, *Request) (*Response, error)

+ OrderingPerNodeArg func(context.Context, *Request) (*Response, error)

+ OrderingQC func(context.Context, *Request) (*Response, error)

+ OrderingUnaryRPC func(context.Context, *Request) (*Response, error)

+ OrderingUnaryRPCConcurrent func(context.Context, *Request) (*Response, error)

+ QuorumCall func(context.Context, *Request) (*Response, error)

+ QuorumCallCombo func(context.Context, *Request) (*Response, error)

+ QuorumCallCustomReturnType func(context.Context, *Request) (*Response, error)

+ QuorumCallEmpty func(context.Context, *empty.Empty) (*Response, error)

+ QuorumCallEmpty2 func(context.Context, *Request) (*empty.Empty, error)

+ QuorumCallFuture func(context.Context, *Request) (*Response, error)

+ QuorumCallFuture2 func(context.Context, *Request) (*Response, error)

+ QuorumCallFutureCombo func(context.Context, *Request) (*Response, error)

+ QuorumCallFutureCustomReturnType func(context.Context, *Request) (*Response, error)

+ QuorumCallFutureEmpty func(context.Context, *Request) (*empty.Empty, error)

+ QuorumCallFutureEmpty2 func(context.Context, *empty.Empty) (*Response, error)

+ QuorumCallFuturePerNodeArg func(context.Context, *Request) (*Response, error)

+ QuorumCallPerNodeArg func(context.Context, *Request) (*Response, error)

+ Unicast func(context.Context, *Request) (*Response, error)

+ Unicast2 func(context.Context, *Request) (*empty.Empty, error)

+ UnicastConcurrent func(context.Context, *Request) (*empty.Empty, error)

+ type ZorumsService_CorrectableStreamClient interface

+ Recv func() (*Response, error)

+ type ZorumsService_CorrectableStreamComboClient interface

+ Recv func() (*Response, error)

+ type ZorumsService_CorrectableStreamComboServer interface

+ Send func(*Response) error

+ type ZorumsService_CorrectableStreamCustomReturnTypeClient interface

+ Recv func() (*Response, error)

+ type ZorumsService_CorrectableStreamCustomReturnTypeServer interface

+ Send func(*Response) error

+ type ZorumsService_CorrectableStreamEmpty2Client interface

+ Recv func() (*Response, error)

+ type ZorumsService_CorrectableStreamEmpty2Server interface

+ Send func(*Response) error

+ type ZorumsService_CorrectableStreamEmptyClient interface

+ Recv func() (*empty.Empty, error)

+ type ZorumsService_CorrectableStreamEmptyServer interface

+ Send func(*empty.Empty) error

+ type ZorumsService_CorrectableStreamPerNodeArgClient interface

+ Recv func() (*Response, error)

+ type ZorumsService_CorrectableStreamPerNodeArgServer interface

+ Send func(*Response) error

+ type ZorumsService_CorrectableStreamServer interface

+ Send func(*Response) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL