proxycodec

Documentation

Index

• Constants
• Variables
• type Codec
  • func NewCodec() *Codec
  • func (c *Codec) Entity(message.Dictionary) codec.CodecEntity
• type CodecEntity
  • func NewCodecEntity() *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    = 2
	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")
)

Types

type Codec

type Codec struct {
}

func NewCodec

func NewCodec() *Codec

func (*Codec) Entity

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

type CodecEntity

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

func NewCodecEntity

func NewCodecEntity() *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