packet

Dec 10, 2025

Changes in this version

+ func CheckHeartbeat(data []byte) (bool, error)

+ func NewPacker(opts ...Option) *defaultPacker

+ func PackBuffer(message *Message) (*buffer.NocopyBuffer, error)

+ func PackHeartbeat() ([]byte, error)

+ func PackMessage(message *Message) ([]byte, error)

+ func ReadBuffer(reader io.Reader) (buffer.Buffer, error)

+ func ReadMessage(reader io.Reader) ([]byte, error)

+ func SetPacker(packer Packer)

+ type Message struct

+ Buffer []byte

+ Route int32

+ Seq int32

+ func UnpackMessage(data []byte) (*Message, error)

+ type NocopyReader interface

+ Next func(n int) (p []byte, err error)

+ Peek func(n int) (buf []byte, err error)

+ Release func() (err error)

+ Slice func(n int) (r NocopyReader, err error)

+ type Option func(o *options)

+ func WithBufferBytes(bufferBytes int) Option

+ func WithByteOrder(byteOrder binary.ByteOrder) Option

+ func WithHeartbeatTime(heartbeatTime bool) Option

+ func WithRouteBytes(routeBytes int) Option

+ func WithSeqBytes(seqBytes int) Option

+ type Packer interface

+ CheckHeartbeat func(data []byte) (bool, error)

+ PackBuffer func(message *Message) (*buffer.NocopyBuffer, error)

+ PackHeartbeat func() ([]byte, error)

+ PackMessage func(message *Message) ([]byte, error)

+ ReadBuffer func(reader io.Reader) (buffer.Buffer, error)

+ ReadMessage func(reader io.Reader) ([]byte, error)

+ UnpackMessage func(data []byte) (*Message, error)

+ func GetPacker() Packer