bsonrpc

package
v0.0.0-...-1dd846c Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 31, 2014 License: MIT Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewClient

func NewClient(conn io.ReadWriteCloser) (c *rpc.Client)

func ServeConn

func ServeConn(conn io.ReadWriteCloser) (s *rpc.Server)

Types

type ClientCodec

type ClientCodec struct {
	Encoder *Encoder
	Decoder *Decoder
	// contains filtered or unexported fields
}

func NewClientCodec

func NewClientCodec(conn io.ReadWriteCloser) (codec *ClientCodec)

func (*ClientCodec) Close

func (cc *ClientCodec) Close() (err error)

func (*ClientCodec) ReadResponseBody

func (cc *ClientCodec) ReadResponseBody(v interface{}) (err error)

func (*ClientCodec) ReadResponseHeader

func (cc *ClientCodec) ReadResponseHeader(res *rpc.Response) (err error)

func (*ClientCodec) WriteRequest

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

type Decoder

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

func NewDecoder

func NewDecoder(r io.Reader) *Decoder

func (*Decoder) Decode

func (d *Decoder) Decode(pv interface{}) (err error)

type Encoder

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

func NewEncoder

func NewEncoder(w io.Writer) *Encoder

func (*Encoder) Encode

func (e *Encoder) Encode(v interface{}) (err error)

type ServerCodec

type ServerCodec struct {
	Encoder *Encoder
	Decoder *Decoder
	// contains filtered or unexported fields
}

func NewServerCodec

func NewServerCodec(conn io.ReadWriteCloser) (codec *ServerCodec)

func (*ServerCodec) Close

func (sc *ServerCodec) Close() (err error)

func (*ServerCodec) ReadRequestBody

func (sc *ServerCodec) ReadRequestBody(v interface{}) (err error)

func (*ServerCodec) ReadRequestHeader

func (sc *ServerCodec) ReadRequestHeader(rq *rpc.Request) (err error)

func (*ServerCodec) WriteResponse

func (sc *ServerCodec) WriteResponse(rs *rpc.Response, v interface{}) (err error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL