codec

Documentation

Index

• Variables
• type Codec
• type Decode
• type Encode
• type VNDCodec
  • func (c *VNDCodec) Decode(data []byte) (m message.Message, err error)
  • func (c *VNDCodec) Encode(m message.Message) (data []byte, err error)

Variables

var (
	NameIsNullError = errors.New("name is ''")
	DataDecodeError = errors.New("data decode error")
)

Types

type Codec

type Codec interface {
	Encode
	Decode
}

type Decode

type Decode interface {
	Decode(data []byte) (m message.Message, err error)
}

type Encode

type Encode interface {
	Encode(m message.Message) (data []byte, err error)
}

type VNDCodec

type VNDCodec struct {
}

VNDCodec 版本域（Version）+ 名域(Name) + 数据域（Data） ┌───────┬───────┬───────┬────────────────┐ │version│ retry │ length│ name │ header ├───────┴───────┴───────┴────────────────┤ │ body │ └────────────────────────────────────────┘

func (*VNDCodec) Decode

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

func (*VNDCodec) Encode

func (c *VNDCodec) Encode(m message.Message) (data []byte, err error)