ConnectionClassForKey determines the ConnectionClass which should be used for traffic addressed to the RKey.

IsLocal returns true if the given InternalClient is local.

NewContext creates an rpc Context with the supplied values.

NewContextWithTestingKnobs creates an rpc Context with the supplied values.

NewDelayingListener creates a net.Listener that introduces a set delay on its connections.

NewInsecureTestingContext creates an insecure rpc Context suitable for tests.

NewInsecureTestingContextWithClusterID creates an insecure rpc Context suitable for tests.

NewInsecureTestingContextWithKnobs creates an insecure rpc Context suitable for tests configured with the provided knobs.

NewServer is a thin wrapper around grpc.NewServer that registers a heartbeat service.

NewServerWithInterceptor is like NewServer, but accepts an additional interceptor which is called before streaming and unary RPCs and may inject an error.

DefaultClass is the default ConnectionClass and should be used for most client traffic.

NumConnectionClasses is the number of valid ConnectionClass values.

SystemClass is the ConnectionClass used for system traffic.

ErrNotHeartbeated is returned by ConnHealth when we have not yet performed the first heartbeat.

Connection is a wrapper around grpc.ClientConn.

Context contains the fields required by the rpc framework.

ContextTestingKnobs provides hooks to aid in testing the system.

A HeartbeatService exposes a method to echo its request params.

Metrics is a metrics struct for Context metrics.

A PingRequest specifies the string to echo in response.

A PingResponse contains the echoed ping request string.

RemoteClockMetrics is the collection of metrics for the clock monitor.

RemoteClockMonitor keeps track of the most recent measurements of remote offsets and round-trip latency from this node to connected nodes.

RemoteOffset keeps track of this client's estimate of its offset from a remote server.

Stats stores network statistics between this node and another.

StatsHandler manages a map of Stats objects, one per connection.

HeartbeatClient is the client API for Heartbeat service.

HeartbeatServer is the server API for Heartbeat service.

TestingHeartbeatStreamClient is the client API for TestingHeartbeatStream service.

TestingHeartbeatStreamServer is the server API for TestingHeartbeatStream service.

ConnectionClass is the identifier of a group of RPC client sessions that are allowed to share an underlying TCP connections; RPC sessions with different connection classes are guaranteed to use separate gRPC client connections.