protocols

type RPC interface {
	PutBlock(ctx context.Context, ref torus.BlockRef, data []byte) error
	Block(ctx context.Context, ref torus.BlockRef) ([]byte, error)
	RebalanceCheck(ctx context.Context, refs []torus.BlockRef) ([]bool, error)
	Close() error

	// This is a little bit of a hack to avoid more allocations.
	WriteBuf(ctx context.Context, ref torus.BlockRef) ([]byte, error)
}

type RPCDialerFunc func(*url.URL, time.Duration, torus.GlobalMetadata) (RPC, error)

type RPCListenerFunc func(*url.URL, RPC, torus.GlobalMetadata) (RPCServer, error)

type RPCServer interface {
	Close() error
}