plaincodec

Documentation

Index

• Constants
• Variables
• type Codec
  • func NewCodec() *Codec
  • func (c *Codec) Entity(dictionary message.Dictionary) codec.CodecEntity
• type CodecEntity
  • func NewCodecEntity(dictionary message.Dictionary) *CodecEntity
  • func (c *CodecEntity) DecodeMessage(data []byte) (*message.Message, error)
  • func (c *CodecEntity) DecodePacket(data []byte) ([]*packet.Packet, error)
  • func (c *CodecEntity) EncodeMessage(m *message.Message) ([]byte, error)
  • func (c *CodecEntity) EncodePacket(packets []*packet.Packet) ([]byte, error)
  • func (c *CodecEntity) String() string

Constants

const (
	HeadLength    = 4
	MaxPacketSize = 64 * 1024 * 1024
)

Variables

var (
	ErrPacketSizeExcced   = errors.New("codec: packet size exceed")
	ErrWrongMessageType   = errors.New("codec: wrong message type")
	ErrInvalidMessage     = errors.New("codec: invalid message")
	ErrInvalidRouteLength = errors.New("codec: invalid route length")
)

Types

type Codec

type Codec struct {
}

func NewCodec

func NewCodec() *Codec

func (*Codec) Entity

func (c *Codec) Entity(dictionary message.Dictionary) codec.CodecEntity

type CodecEntity

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

func NewCodecEntity

func NewCodecEntity(dictionary message.Dictionary) *CodecEntity

func (*CodecEntity) DecodeMessage

func (c *CodecEntity) DecodeMessage(data []byte) (*message.Message, error)

func (*CodecEntity) DecodePacket

func (c *CodecEntity) DecodePacket(data []byte) ([]*packet.Packet, error)

func (*CodecEntity) EncodeMessage

func (c *CodecEntity) EncodeMessage(m *message.Message) ([]byte, error)

func (*CodecEntity) EncodePacket

func (c *CodecEntity) EncodePacket(packets []*packet.Packet) ([]byte, error)

func (*CodecEntity) String

func (c *CodecEntity) String() string