Versions in this module Expand all Collapse all v2 v2.0.0 Oct 28, 2022 Changes in this version + func CallWithCodec(cc rpc.ClientCodec, method string, args interface{}, resp interface{}) error + func Dial(network, address string) (*rpc.Client, error) + func NewClient(conn io.ReadWriteCloser) *rpc.Client + func NewClientCodec(conn io.ReadWriteCloser) rpc.ClientCodec + func NewServerCodec(conn io.ReadWriteCloser) rpc.ServerCodec + func ServeConn(conn io.ReadWriteCloser) + type MsgpackCodec struct + func NewCodec(bufReads, bufWrites bool, conn io.ReadWriteCloser) *MsgpackCodec + func NewCodecFromHandle(bufReads, bufWrites bool, conn io.ReadWriteCloser, h *codec.MsgpackHandle) *MsgpackCodec + func (cc *MsgpackCodec) Close() error + func (cc *MsgpackCodec) ReadRequestBody(out interface{}) error + func (cc *MsgpackCodec) ReadRequestHeader(r *rpc.Request) error + func (cc *MsgpackCodec) ReadResponseBody(out interface{}) error + func (cc *MsgpackCodec) ReadResponseHeader(r *rpc.Response) error + func (cc *MsgpackCodec) WriteRequest(r *rpc.Request, body interface{}) error + func (cc *MsgpackCodec) WriteResponse(r *rpc.Response, body interface{}) error
Go to main page