coder

package

v3.4.1 Latest Latest Go to latest Published: Nov 19, 2025 License: Apache-2.0 Imports: 5 Imported by: 1

Details

View Source

const (
	MessageLength13Base = 13
	MessageLength14Base = 269
	MessageLength15Base = 65805
)

View Source

var (
	ErrMessageTruncated      = errors.New("message is truncated")
	ErrMessageInvalidVersion = errors.New("message has invalid version")
)

View Source

var DefaultCoder = new(Coder)

This section is empty.

type Coder struct{}

func (c *Coder) Decode(data []byte, m *message.Message) (int, error)

func (c *Coder) DecodeHeader(data []byte, h *MessageHeader) (int, error)

func (c *Coder) DecodeWithHeader(data []byte, header MessageHeader, m *message.Message) (int, error)

func (c *Coder) Encode(m message.Message, buf []byte) (int, error)

func (c *Coder) Size(m message.Message) (int, error)

type MessageHeader struct {
	Token         []byte
	Length        uint32
	MessageLength uint32
	Code          codes.Code
}