Versions in this module Expand all Collapse all v0 v0.1.0 Jun 1, 2016 Changes in this version + func RegisterRPCDialer(scheme string, newFunc RPCDialerFunc) + func RegisterRPCListener(scheme string, newFunc RPCListenerFunc) + type RPC interface + Block func(ctx context.Context, ref torus.BlockRef) ([]byte, error) + Close func() error + PutBlock func(ctx context.Context, ref torus.BlockRef, data []byte) error + RebalanceCheck func(ctx context.Context, refs []torus.BlockRef) ([]bool, error) + WriteBuf func(ctx context.Context, ref torus.BlockRef) ([]byte, error) + func DialRPC(url *url.URL, timeout time.Duration, gmd torus.GlobalMetadata) (RPC, 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 func() error + func ListenRPC(url *url.URL, handler RPC, gmd torus.GlobalMetadata) (RPCServer, error)
Go to main page