client

package

Go to main page

Versions in this module

v0

v0.5.0

Oct 27, 2025

Changes in this version

type Client

+ func (c *Client) InitModule(mods *modules.Core)

type Config

+ Timeout time.Duration

v0.4.0

Dec 6, 2021

v0.3.1

Aug 29, 2021

v0.3.0

Aug 27, 2021

Changes in this version

type Client

+ func New(conf Config, builder modules.Builder) (client *Client)

+ func (c *Client) Connect(replicaConfig *config.ReplicaConfig) (err error)

+ func (c *Client) Run(ctx context.Context)

+ func (c *Client) Start()

+ func (c *Client) Stop()

+ type Config struct

+ ID hotstuff.ID

+ Input io.ReadCloser

+ ManagerOptions []gorums.ManagerOption

+ MaxConcurrent uint32

+ PayloadSize uint32

+ RateLimit float64

+ RateStep float64

+ RateStepInterval time.Duration

+ RootCAs *x509.CertPool

+ TLS bool

+ type LatencyMeasurementEvent struct

+ Latency time.Duration

v0.2.2

Feb 17, 2021

v0.2.1

Feb 17, 2021

v0.2.0

Feb 12, 2021

Changes in this version

+ func RegisterClientServer(srv *gorums.Server, impl Client)

+ type AsyncEmpty struct

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

+ type Batch struct

+ Commands []*Command

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

+ func (*Batch) ProtoMessage()

+ func (x *Batch) GetCommands() []*Command

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

+ func (x *Batch) Reset()

+ func (x *Batch) String() string

v0.1.0

Jul 29, 2020

Changes in this version

+ const LevelNotSet

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

+ var File_client_client_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 BenchmarkData struct

+ LatencyVariance float64

+ MeasuredLatency float64

+ MeasuredThroughput float64

+ Stats []*CommandStats

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

+ func (*BenchmarkData) ProtoMessage()

+ func (x *BenchmarkData) GetLatencyVariance() float64

+ func (x *BenchmarkData) GetMeasuredLatency() float64

+ func (x *BenchmarkData) GetMeasuredThroughput() float64

+ func (x *BenchmarkData) GetStats() []*CommandStats

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

+ func (x *BenchmarkData) Reset()

+ func (x *BenchmarkData) String() string

+ type Client interface

+ ExecCommand func(context.Context, *Command, func(*Empty, error))

+ type Command struct

+ ClientID uint32

+ Data []byte

+ SequenceNumber uint64

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

+ func (*Command) ProtoMessage()

+ func (x *Command) GetClientID() uint32

+ func (x *Command) GetData() []byte

+ func (x *Command) GetSequenceNumber() uint64

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

+ func (x *Command) Reset()

+ func (x *Command) String() string

+ type CommandStats struct

+ Duration *duration.Duration

+ StartTime *timestamp.Timestamp

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

+ func (*CommandStats) ProtoMessage()

+ func (x *CommandStats) GetDuration() *duration.Duration

+ func (x *CommandStats) GetStartTime() *timestamp.Timestamp

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

+ func (x *CommandStats) Reset()

+ func (x *CommandStats) String() string

+ type ConfigNotFoundError uint32

+ func (e ConfigNotFoundError) Error() string

+ type Configuration struct

+ func NewConfig(qspec QuorumSpec, opts ...ManagerOption) (*Configuration, func(), error)

+ func (c *Configuration) ExecCommand(ctx context.Context, in *Command) *FutureEmpty

+ func (c *Configuration) ID() uint32

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

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

+ func (c *Configuration) Size() int

+ func (c *Configuration) String() string

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

+ type Empty struct

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

+ func (*Empty) ProtoMessage()

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

+ func (x *Empty) Reset()

+ func (x *Empty) String() string

+ type FutureEmpty struct

+ NodeIDs []uint32

+ func (f *FutureEmpty) Done() bool

+ func (f *FutureEmpty) Get() (*Empty, 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) RegisterClientServer(srv Client)

+ 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(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 WithMetadata(md metadata.MD) ManagerOption

+ func WithNoConnect() ManagerOption

+ func WithNodeList(addrsList []string) ManagerOption

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

+ func WithPerNodeMetadata(f func(uint32) metadata.MD) 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

+ 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

+ ExecCommandQF func(in *Command, replies map[uint32]*Empty) (*Empty, bool)

+ 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