dummyclient

Documentation

Index

• type DummyClient
  • func NewDummyClient(clientId t.ClientID, hasher modules.Hasher, crypto modules.Crypto, ...) *DummyClient
  • func (dc *DummyClient) Connect(ctx context.Context, membership map[t.NodeID]string)
  • func (dc *DummyClient) Disconnect()
  • func (dc *DummyClient) SubmitRequest(data []byte) error

Types

type DummyClient

type DummyClient struct {
	// contains filtered or unexported fields
}

func NewDummyClient

func NewDummyClient(clientId t.ClientID, hasher modules.Hasher, crypto modules.Crypto, l logging.Logger) *DummyClient

func (*DummyClient) Connect

func (dc *DummyClient) Connect(ctx context.Context, membership map[t.NodeID]string)

Connect establishes (in parallel) network connections to all nodes in the system. The nodes' RequestReceivers must be running. Only after Connect() returns, sending requests through this DummyClient is possible. TODO: Deal with errors, e.g. when the connection times out (make sure the RPC call in connectToNode() has a timeout).

func (*DummyClient) Disconnect

func (dc *DummyClient) Disconnect()

Disconnect closes all open connections to MirBFT nodes.

func (*DummyClient) SubmitRequest

func (dc *DummyClient) SubmitRequest(data []byte) error

SubmitRequest submits a request by sending it to all nodes (as configured when creating the DummyClient). It automatically appends meta-info like client ID and request number. SubmitRequest must not be called concurrently. If an error occurs, SubmitRequest returns immediately, even if sending of the request was not attempted for all nodes.