serialize

Documentation

Index

• func Compose(cmd *protocol.Command) ([]byte, error)
• func Parse(data []byte) (cmd *protocol.Command, err error)
• func Register(serializer *Serializer)
• type ParseEngine
• type Parser
  • func NewParser(r io.Reader) (parser *Parser)
  • func (parser *Parser) Close() error
  • func (parser *Parser) ReadCommand() (cmd *protocol.Command, err error)
• type Serializer

Functions

func Compose

func Compose(cmd *protocol.Command) ([]byte, error)

Compose 将信令编码

func Parse

func Parse(data []byte) (cmd *protocol.Command, err error)

Parse 通过字节解析

func Register

func Register(serializer *Serializer)

Register 注册串行化新建函数

Types

type ParseEngine

type ParseEngine interface {
	Parse(br *bufio.Reader) (cmd *protocol.Command, err error)
	Close() error
}

ParseEngine 解析引擎函数

type Parser

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

Parser 解析器

func NewParser

func NewParser(r io.Reader) (parser *Parser)

NewParser 新建解析器

func (*Parser) Close

func (parser *Parser) Close() error

Close 关闭

func (*Parser) ReadCommand

func (parser *Parser) ReadCommand() (cmd *protocol.Command, err error)

ReadCommand 将数据写入解析器，如果能够解析出命令，则回调

type Serializer

type Serializer struct {
	// Version 串行化版本
	Version string
	// ProbeByte 协议首字节
	ProbeByte byte
	// NewParseEngine 解析信令
	NewParseEngine func() (engine ParseEngine)
	// Compose 将信令编码
	Compose func(cmd *protocol.Command) ([]byte, error)
}

Serializer 串行化函数，所有实现都必须完成以下函数