rpc

Mar 18, 2022

Changes in this version

+ const MaxServiceIDLength

type Call

+ StreamArgs reflect.Value

+ StreamReplies reflect.Value

type Client

+ func (c *Client) MultiStream(ctxs []context.Context, dests []peer.ID, svcName, svcMethod string, ...) []error

+ func (c *Client) Stream(ctx context.Context, dest peer.ID, svcName, svcMethod string, ...) error

type ClientOption

+ func WithMultiStreamBufferSize(size int) ClientOption

+ type ErrorType int

+ const AuthorizationErr

+ const ClientErr

+ const NonRPCErr

+ const ServerErr

type Response

+ Data interface{}

type ServerOption

+ func WithStreamBufferSize(size int) ServerOption

type ServiceID

+ func (svcID ServiceID) String() string

Jun 1, 2021

Changes in this version

+ const ContextKeyRequestSender

+ func GetRequestSender(ctx context.Context) (peer.ID, error)

+ type ContextKey string

Mar 2, 2019

Changes in this version

+ func AuthorizeWithMap(p map[peer.ID]map[string]bool) func(pid peer.ID, svc string, method string) bool

+ func IsAuthorizationError(err error) bool

+ func IsClientError(err error) bool

+ func IsRPCError(err error) bool

+ func IsServerError(err error) bool

+ type Call struct

+ Args interface{}

+ Dest peer.ID

+ Done chan *Call

+ Error error

+ Reply interface{}

+ SvcID ServiceID

+ type Client struct

+ func NewClient(h host.Host, p protocol.ID, opts ...ClientOption) *Client

+ func NewClientWithServer(h host.Host, p protocol.ID, s *Server, opts ...ClientOption) *Client

+ func (c *Client) Call(dest peer.ID, svcName, svcMethod string, args, reply interface{}) error

+ func (c *Client) CallContext(ctx context.Context, dest peer.ID, svcName, svcMethod string, ...) error

+ func (c *Client) Go(dest peer.ID, svcName, svcMethod string, args, reply interface{}, ...) error

+ func (c *Client) GoContext(ctx context.Context, dest peer.ID, svcName, svcMethod string, ...) error

+ func (c *Client) ID() peer.ID

+ func (c *Client) MultiCall(ctxs []context.Context, dests []peer.ID, svcName, svcMethod string, ...) []error

+ func (c *Client) MultiGo(ctxs []context.Context, dests []peer.ID, svcName, svcMethod string, ...) error

+ type ClientOption func(*Client)

+ func WithClientStatsHandler(h stats.Handler) ClientOption

+ type Response struct

+ ErrType responseErr

+ Error string

+ Service ServiceID

+ type Server struct

+ func NewServer(h host.Host, p protocol.ID, opts ...ServerOption) *Server

+ func (server *Server) Call(call *Call) error

+ func (server *Server) ID() peer.ID

+ func (server *Server) Register(rcvr interface{}) error

+ func (server *Server) RegisterName(name string, rcvr interface{}) error

+ type ServerOption func(*Server)

+ func WithAuthorizeFunc(a func(pid peer.ID, name string, method string) bool) ServerOption

+ func WithServerStatsHandler(h stats.Handler) ServerOption

+ type ServiceID struct

+ Method string

+ Name string