Versions in this module Expand all Collapse all v1 v1.0.1 Mar 18, 2021 v1.0.0 Mar 17, 2021 Changes in this version + const RpcdSourceGrowerGateway + var ErrShutdown = errors.New("connection is shut down") + func NewPbClientCodec(conn io.ReadWriteCloser) *pbClientCodec + func NewPbServerCode(conn io.ReadWriteCloser) *pbServerCodec + type Call struct + Args interface{} + Done chan *Call + Error error + Reply interface{} + ServiceMethod string + type Client struct + func Dial(network, address string, opts ...DialOption) (*Client, error) + func NewClientWithCodec(codec ClientCodec) *Client + func (client *Client) Call(serviceMethod string, args interface{}, reply interface{}) error + func (client *Client) Close() error + func (client *Client) ClosedOrShutdowned() bool + func (client *Client) Go(serviceMethod string, args interface{}, reply interface{}, done chan *Call) *Call + type ClientCodec interface + Close func() error + ReadResponseBody func(interface{}) error + ReadResponseHeader func(*Response) error + WriteRequest func(*Request, interface{}) error + type DialOption interface + func WithTimeout(seconds time.Duration) DialOption + type RPCServer struct + func NewRPCServer() *RPCServer + func (rs *RPCServer) ServeWithPbCodec(addr string) error + func (server *RPCServer) RegisterName(name string, rcvr interface{}, routes map[string]string) error + func (server *RPCServer) ServeCodec(codec ServerCodec) + func (server *RPCServer) ServeRequest(codec ServerCodec) error + type Request struct + Seq uint64 + ServiceMethod string + type RequestHeader struct + Checksum uint32 + Id uint64 + Method string + RpcdSource string + func (*RequestHeader) ProtoMessage() + func (m *RequestHeader) Check(body []byte) error + func (m *RequestHeader) Reset() + func (m *RequestHeader) String() string + type Response struct + Error string + Seq uint64 + ServiceMethod string + type ResponseHeader struct + Checksum uint32 + Error string + Id uint64 + Method string + func (*ResponseHeader) ProtoMessage() + func (m *ResponseHeader) Check(body []byte) error + func (m *ResponseHeader) Reset() + func (m *ResponseHeader) String() string + type ServerCodec interface + Close func() error + ReadRequestBody func(interface{}) error + ReadRequestHeader func(*Request) error + WriteResponse func(*Response, interface{}) error + type ServerError string + func (e ServerError) Error() string + type SugarCoatingRequest struct + Data []byte + RpcdSource string + func GenSugarCoatingRequest(source string, data []byte) *SugarCoatingRequest + func (*SugarCoatingRequest) ProtoMessage() + func (m *SugarCoatingRequest) Reset() + func (m *SugarCoatingRequest) String() string + type SugarCoatingResponse struct + Data []byte + func (*SugarCoatingResponse) ProtoMessage() + func (m *SugarCoatingResponse) GetSugarData() ([]byte, error) + func (m *SugarCoatingResponse) Reset() + func (m *SugarCoatingResponse) String() string + type SugarCoatingResponseInterface interface + GetSugarData func() ([]byte, error)