conn

Documentation

Index

• type ClientCodec
  • func (c *ClientCodec) Close() error
  • func (c *ClientCodec) ReadResponseBody(body interface{}) error
  • func (c *ClientCodec) ReadResponseHeader(r *rpc.Response) error
  • func (c *ClientCodec) WriteRequest(r *rpc.Request, body interface{}) error
• type Pool
  • func NewPool(addr string, maxCap int) *Pool
  • func (p *Pool) Call(serviceMethod string, args interface{}, reply interface{}) error
  • func (p *Pool) Close() error
• type Query
• type Reply
• type ServerCodec
  • func (c *ServerCodec) Close() error
  • func (c *ServerCodec) ReadRequestBody(data interface{}) error
  • func (c *ServerCodec) ReadRequestHeader(r *rpc.Request) error
  • func (c *ServerCodec) WriteResponse(resp *rpc.Response, data interface{}) error

Types

type ClientCodec

type ClientCodec struct {
	Rwc io.ReadWriteCloser
	// contains filtered or unexported fields
}

func (*ClientCodec) Close

func (c *ClientCodec) Close() error

func (*ClientCodec) ReadResponseBody

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

func (*ClientCodec) ReadResponseHeader

func (c *ClientCodec) ReadResponseHeader(r *rpc.Response) error

func (*ClientCodec) WriteRequest

func (c *ClientCodec) WriteRequest(r *rpc.Request, body interface{}) error

type Pool

type Pool struct {
	Addr string
	// contains filtered or unexported fields
}

func NewPool

func NewPool(addr string, maxCap int) *Pool

func (*Pool) Call

func (p *Pool) Call(serviceMethod string, args interface{},
	reply interface{}) error

func (*Pool) Close

func (p *Pool) Close() error

type Query

type Query struct {
	Data []byte
}

type Reply

type Reply struct {
	Data []byte
}

type ServerCodec

type ServerCodec struct {
	Rwc io.ReadWriteCloser
	// contains filtered or unexported fields
}

func (*ServerCodec) Close

func (c *ServerCodec) Close() error

func (*ServerCodec) ReadRequestBody

func (c *ServerCodec) ReadRequestBody(data interface{}) error

func (*ServerCodec) ReadRequestHeader

func (c *ServerCodec) ReadRequestHeader(r *rpc.Request) error

func (*ServerCodec) WriteResponse

func (c *ServerCodec) WriteResponse(resp *rpc.Response,
	data interface{}) error