rpc

Documentation

Index

• type Sender
  • func (s *Sender) Send(_ context.Context, call proto.Call)

Types

type Sender

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

Sender is an implementation of Sender which exposes the Key-Value database provided by a Cockroach cluster by connecting via RPC to a Cockroach node. Overly-busy nodes will redirect this client to other nodes.

TODO(pmattis): This class is insufficiently tested and not intended for use outside of benchmarking.

func (*Sender) Send

func (s *Sender) Send(_ context.Context, call proto.Call)

Send sends call to Cockroach via an RPC request. Errors which are retryable are retried with backoff in a loop using the default retry options. Other errors sending the request are retried indefinitely using the same client command ID to avoid reporting failure when in fact the command may have gone through and been executed successfully. We retry here to eventually get through with the same client command ID and be given the cached response.