NewContext creates an rpc Context with the supplied values.

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.

ErrNotConnected is returned by ConnHealth when there is no connection to the host (e.g.

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.

A HeartbeatService exposes a method to echo its request params.

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.