Documentation ¶
Index ¶
- type ClientWorker
- func (c *ClientWorker) Broadcast(req *commandpb.Command) (*commandpb.CommandResult, error)
- func (c *ClientWorker) Dester(req *commandpb.Command) (*commandpb.CommandResult, error)
- func (c *ClientWorker) Generic(req *commandpb.Command) (*commandpb.CommandResult, error)
- func (c *ClientWorker) Init(reqFunc func(*commandpb.Command) (*commandpb.CommandResult, error))
- func (c *ClientWorker) MultiPrimary(req *commandpb.Command) (*commandpb.CommandResult, error)
- func (c *ClientWorker) MultiPrimaryRRTarget(req *commandpb.Command) (*commandpb.CommandResult, error)
- func (c *ClientWorker) Prime(req *commandpb.Command) (*commandpb.CommandResult, error)
- func (c *ClientWorker) Run()
- func (c *ClientWorker) SBFT(req *commandpb.Command) (*commandpb.CommandResult, error)
- func (c *ClientWorker) ThresholdMultiPrimary(req *commandpb.Command) (*commandpb.CommandResult, error)
- type Payload
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ClientWorker ¶
type ClientWorker struct {
// contains filtered or unexported fields
}
func NewClientWorker ¶
func NewClientWorker( conn *connection.Connection, logger logger.Logger, config *masterpb.ClientConfig, appID, cID uint32, localIDs []int, metricC chan float64, nextIDPtr *uint64, ) *ClientWorker
func (*ClientWorker) Broadcast ¶
func (c *ClientWorker) Broadcast( req *commandpb.Command, ) (*commandpb.CommandResult, error)
func (*ClientWorker) Dester ¶
func (c *ClientWorker) Dester( req *commandpb.Command, ) (*commandpb.CommandResult, error)
func (*ClientWorker) Generic ¶
func (c *ClientWorker) Generic( req *commandpb.Command, ) (*commandpb.CommandResult, error)
func (*ClientWorker) Init ¶
func (c *ClientWorker) Init( reqFunc func(*commandpb.Command) (*commandpb.CommandResult, error), )
func (*ClientWorker) MultiPrimary ¶
func (c *ClientWorker) MultiPrimary( req *commandpb.Command, ) (*commandpb.CommandResult, error)
func (*ClientWorker) MultiPrimaryRRTarget ¶
func (c *ClientWorker) MultiPrimaryRRTarget( req *commandpb.Command, ) (*commandpb.CommandResult, error)
func (*ClientWorker) Prime ¶
func (c *ClientWorker) Prime( req *commandpb.Command, ) (*commandpb.CommandResult, error)
func (*ClientWorker) Run ¶
func (c *ClientWorker) Run()
func (*ClientWorker) SBFT ¶
func (c *ClientWorker) SBFT( req *commandpb.Command, ) (*commandpb.CommandResult, error)
func (*ClientWorker) ThresholdMultiPrimary ¶
func (c *ClientWorker) ThresholdMultiPrimary( req *commandpb.Command, ) (*commandpb.CommandResult, error)
Click to show internal directories.
Click to hide internal directories.