plaincodec

Documentation

Index

• Constants
• Variables
• type AtomicBool
  • func (ab *AtomicBool) Load() bool
  • func (ab *AtomicBool) Store(b bool)
• type AtomicInt32
  • func (ab *AtomicInt32) Load() int32
  • func (ab *AtomicInt32) Store(b int32)
• 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)

Constants

const (
	HeadLength    = 4
	MaxPacketSize = 64 * 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 AtomicBool

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

AtomicBool is a wrapper for atomic int32

func (*AtomicBool) Load

func (ab *AtomicBool) Load() bool

Load atomicly load bool value

func (*AtomicBool) Store

func (ab *AtomicBool) Store(b bool)

Store atomicly store bool value

type AtomicInt32

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

func (*AtomicInt32) Load

func (ab *AtomicInt32) Load() int32

Load atomicly load bool value

func (*AtomicInt32) Store

func (ab *AtomicInt32) Store(b int32)

Store atomicly store bool value

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)