codec

Documentation

Index

• type ClientCodec
  • func NewClientCodec(conn io.ReadWriteCloser, s serialize.Serializer, ct compress.Type) *ClientCodec
  • func (cc *ClientCodec) Close() error
  • func (cc *ClientCodec) ReadResponseBody(body interface{}) error
  • func (cc *ClientCodec) ReadResponseHeader(resp *rpc.Response) error
  • func (cc *ClientCodec) WriteRequest(req *rpc.Request, body interface{}) error
• type ServerCodec
  • func NewServerCodec(conn io.ReadWriteCloser, s serialize.Serializer) *ServerCodec
  • func (cc *ServerCodec) Close() error
  • func (cc *ServerCodec) ReadRequestBody(body interface{}) error
  • func (cc *ServerCodec) ReadRequestHeader(req *rpc.Request) error
  • func (cc *ServerCodec) WriteResponse(resp *rpc.Response, body interface{}) error

Types

type ClientCodec

type ClientCodec struct {
	CompressType compress.Type
	// contains filtered or unexported fields
}

func NewClientCodec

func NewClientCodec(conn io.ReadWriteCloser, s serialize.Serializer, ct compress.Type) *ClientCodec

func (*ClientCodec) Close

func (cc *ClientCodec) Close() error

func (*ClientCodec) ReadResponseBody

func (cc *ClientCodec) ReadResponseBody(body interface{}) error

func (*ClientCodec) ReadResponseHeader

func (cc *ClientCodec) ReadResponseHeader(resp *rpc.Response) error

func (*ClientCodec) WriteRequest

func (cc *ClientCodec) WriteRequest(req *rpc.Request, body interface{}) error

type ServerCodec

type ServerCodec struct {
	// contains filtered or unexported fields
}

func NewServerCodec

func NewServerCodec(conn io.ReadWriteCloser, s serialize.Serializer) *ServerCodec

func (*ServerCodec) Close

func (cc *ServerCodec) Close() error

func (*ServerCodec) ReadRequestBody

func (cc *ServerCodec) ReadRequestBody(body interface{}) error

func (*ServerCodec) ReadRequestHeader

func (cc *ServerCodec) ReadRequestHeader(req *rpc.Request) error

func (*ServerCodec) WriteResponse

func (cc *ServerCodec) WriteResponse(resp *rpc.Response, body interface{}) error