ordering

package

Go to main page

Versions in this module

v0

v0.10.0

Nov 14, 2025

Changes in this version

type Request

+ func (x *Request) SetNum(v uint64)

+ type Request_builder struct

+ Num uint64

+ func (b0 Request_builder) Build() *Request

type Response

+ func (x *Response) SetInOrder(v bool)

+ type Response_builder struct

+ InOrder bool

+ func (b0 Response_builder) Build() *Response

v0.9.0

Apr 7, 2025

v0.8.1

Mar 5, 2025

v0.8.0

Mar 5, 2025

Changes in this version

+ type GorumsTestClient interface

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

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

+ type GorumsTestNodeClient interface

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

+ type GorumsTestServer interface

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

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

+ UnaryRPC 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

+ func RegisterGorumsTestServer(srv *gorums.Server, impl GorumsTest)

+ type AsyncResponse struct

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

type Configuration

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

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

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

type GorumsTest

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

type QuorumSpec

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

v0.2.0

Jun 29, 2020

Changes in this version

+ const LevelNotSet

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

+ var File_ordering_order_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

+ 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) ID() uint32

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

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

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

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

+ func (c *Configuration) Size() int

+ func (c *Configuration) String() string

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

+ 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) RegisterGorumsTestServer(srv GorumsTest)

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

+ func (s *GorumsServer) Stop()

+ type GorumsTest interface

+ QC func(*Request) *Response

+ QCFuture func(*Request) *Response

+ UnaryRPC func(*Request) *Response

+ 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 Node struct

+ func (n *Node) Address() string

+ func (n *Node) FullString() string

+ func (n *Node) ID() uint32

+ func (n *Node) LastErr() error

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

+ func (n *Node) Port() string

+ func (n *Node) String() string

+ func (n *Node) UnaryRPC(ctx context.Context, in *Request, opts ...grpc.CallOption) (resp *Response, err 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

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

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

+ type Request struct

+ Num uint64

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

+ func (*Request) ProtoMessage()

+ func (x *Request) GetNum() uint64

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

+ func (x *Request) Reset()

+ func (x *Request) String() string

+ type Response struct

+ InOrder bool

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

+ func (*Response) ProtoMessage()

+ func (x *Response) GetInOrder() bool

+ 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

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