bsonrpc

package

v0.0.0-...-be8dc82 Latest Latest Go to latest Published: Jul 22, 2021 License: BSD-3-Clause Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

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

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

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

func NewClientCodec(conn io.ReadWriteCloser) *ClientCodec

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

func (client *ClientCodec) ReadResponseBody(v interface{}) error

1. 读取并解码V

func (client *ClientCodec) ReadResponseHeader(res *rpc.Response) error

1. 读取并解码rpc.Response

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

1. 写入rpc.Request 2. 写入BSON编码的v

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

func NewDecoder(r io.Reader) *Decoder

func (decoder *Decoder) Decode(pv interface{}) error

从io.Reader读取数据, 并解码到pv

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

func NewEncoder(w io.Writer) *Encoder

func (encoder *Encoder) Encode(v interface{}) error

编码v, 将序列化的数据写到io.Writer

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

func NewServerCodec(conn io.ReadWriteCloser) *ServerCodec

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

func (server *ServerCodec) ReadRequestBody(v interface{}) error

1. 读取并解码V

func (server *ServerCodec) ReadRequestHeader(rq *rpc.Request) error

1. 读取并解码rpc.Request

func (server *ServerCodec) WriteResponse(res *rpc.Response, v interface{}) error

1. 写入rpc.Response 2. 写入BSON编码的v