protocols

Documentation

Index

• func RegisterRPCDialer(scheme string, newFunc RPCDialerFunc)
• func RegisterRPCListener(scheme string, newFunc RPCListenerFunc)
• type RPC
  • func DialRPC(url *url.URL, timeout time.Duration, gmd torus.GlobalMetadata) (RPC, error)
• type RPCDialerFunc
• type RPCListenerFunc
• type RPCServer
  • func ListenRPC(url *url.URL, handler RPC, gmd torus.GlobalMetadata) (RPCServer, error)

Functions

func RegisterRPCDialer

func RegisterRPCDialer(scheme string, newFunc RPCDialerFunc)

func RegisterRPCListener

func RegisterRPCListener(scheme string, newFunc RPCListenerFunc)

Types

type RPC

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)
}

func DialRPC

func DialRPC(url *url.URL, timeout time.Duration, gmd torus.GlobalMetadata) (RPC, error)

type RPCDialerFunc

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

type RPCListenerFunc

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

type RPCServer

type RPCServer interface {
	Close() error
}

func ListenRPC

func ListenRPC(url *url.URL, handler RPC, gmd torus.GlobalMetadata) (RPCServer, error)