codec

Dec 5, 2022

Changes in this version

type Packet

+ func (p *Packet) EncodeWith(action, seq int16, data any) ([]byte, error)

Nov 20, 2022

Changes in this version

+ func NewLengthFieldBasedFromDecoder(conn net.Conn, offset int) net.Conn

+ func NewWebsocketClientDecoder(conn net.Conn) *websocketDecoder

+ func NewWebsocketDecoder(conn net.Conn) net.Conn

+ type LengthFieldBasedFrameDecoder struct

+ func (c *LengthFieldBasedFrameDecoder) SyscallConn() (syscall.RawConn, error)

+ func (decoder *LengthFieldBasedFrameDecoder) Read(bytes []byte) (n int, err error)

+ func (decoder *LengthFieldBasedFrameDecoder) Write(buf []byte) (n int, err error)

Nov 14, 2022

Changes in this version

+ var ErrInvalidProtoMessage = errors.New("invalid proto message")

type Codec

+ Marshal func(data any) ([]byte, error)

+ Unmarshal func(p []byte, data any) error

type Decoder

+ DecodeBytes func(bytes []byte) (buf []byte, err error)

+ Encode func(writer io.Writer, buf []byte) (n int, err error)

+ type JsonCodec struct

+ func NewJsonCodec() *JsonCodec

+ func (codec *JsonCodec) Marshal(data any) ([]byte, error)

+ func (codec *JsonCodec) Unmarshal(p []byte, data any) error

type LineBasedFrameDecoder

+ func (decoder *LineBasedFrameDecoder) DecodeBytes(bytes []byte) (buf []byte, err error)

+ func (decoder *LineBasedFrameDecoder) Encode(writer io.Writer, buf []byte) (n int, err error)

type Options

+ func DefaultOptions() *Options

type Packet

+ Action int16

+ func NewPacket(codec Codec) *Packet

+ func (p *Packet) Pack() ([]byte, error)

+ func (p *Packet) Unpack(msg []byte) *Packet

+ type ProtoCodec struct

+ func NewProtoCodec() *ProtoCodec

+ func (codec *ProtoCodec) Marshal(data any) ([]byte, error)

+ func (codec *ProtoCodec) Unmarshal(p []byte, data any) error

Nov 10, 2022

Changes in this version

+ const OptionContentTypeJson

+ func SetEndian(endian binary.Endian)

type Codec

+ func Factory() *Codec

+ func (codec *Codec) NewPacket(header Header) *Packet

+ func (codec *Codec) UnpackPacket(msg []byte) (*Packet, error)

+ type Decoder interface

+ Decode func(reader io.Reader, bytes []byte) (n int, err error)

+ func NewDecoder(packetLengthSize int) Decoder

type Header

+ Options int16

+ func (header Header) IsContentTypeJson() bool

+ type LineBasedFrameDecoder struct

+ func (decoder *LineBasedFrameDecoder) Decode(reader io.Reader, bytes []byte) (n int, err error)

type Packet

+ func (packet *Packet) Decode(data any) error

+ func (packet *Packet) Encode(data any) ([]byte, error)

Oct 31, 2022

Changes in this version

+ type Header struct

+ ContentType int16

+ Operate int16

+ Seq int16

type Packet

+ Header Header

Oct 21, 2022

Changes in this version

+ const ContentTypeJSON

+ const ContentTypeProtobuf

+ type Codec interface

+ Pack func(packet *Packet, data any) ([]byte, error)

+ Unpack func(packet *Packet, msg []byte) error

+ func Default(opts ...Option) Codec

+ type DefaultCodec struct

+ func (codec DefaultCodec) Pack(packet *Packet, data any) ([]byte, error)

+ func (codec DefaultCodec) Unpack(packet *Packet, msg []byte) error

+ type Option func(options *Options)

+ type Options struct

+ ContentType int

+ type Packet struct

+ Body []byte

+ ContentType int16

+ Operate int16

+ Seq int16

+ func (packet *Packet) Marshal(data any) ([]byte, error)

+ func (packet *Packet) Reset()

+ func (packet *Packet) Unmarshal(data any) error