Versions in this module Expand all Collapse all v0 v0.2.0 Aug 20, 2021 v0.1.1 Jul 8, 2021 Changes in this version + const MaxMessageSize + type Conn struct + Decode Decoder + Encode Encoder + InMsg proto.Message + OutMsg proto.Message + Stream grpc.Stream + WriteLock *sync.Mutex + func (c *Conn) Close() error + func (c *Conn) LocalAddr() net.Addr + func (c *Conn) Read(p []byte) (n int, err error) + func (c *Conn) RemoteAddr() net.Addr + func (c *Conn) SetDeadline(time.Time) error + func (c *Conn) SetReadDeadline(time.Time) error + func (c *Conn) SetWriteDeadline(time.Time) error + func (c *Conn) Write(p []byte) (int, error) + type Decoder func(m proto.Message, offset int, p []byte) ([]byte, error) + func Decode(f func(proto.Message) *[]byte) Decoder + type Encoder func(proto.Message, []byte) (int, error) + func ChunkedEncoder(enc Encoder, size int) Encoder + func Encode(f func(proto.Message) *[]byte) Encoder