conn

package

v0.0.0-...-e3835e8 Latest Latest Go to latest Published: Apr 14, 2016 License: Apache-2.0 Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

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 struct {
	Addr string
	// contains filtered or unexported fields
}

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 struct {
	Data []byte
}

type Reply struct {
	Data []byte
}

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

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