message

Documentation

Index

• func NewOptions() *options
• type IMessage
• type Message
  • func (p *Message) Execute() error
  • func (p *Message) IsPassThrough() bool
  • func (p *Message) JsonUnmarshal(data []byte) (message proto.Message, err error)
  • func (p *Message) Marshal(message proto.Message) (data []byte, err error)
  • func (p *Message) Unmarshal(data []byte) (message proto.Message, err error)
• type Mgr
  • func NewMgr() *Mgr
  • func (p *Mgr) Find(messageID uint32) IMessage
  • func (p *Mgr) Register(messageID uint32, opts ...*options)
  • func (p *Mgr) Replace(messageID uint32, opt *options)

Functions

func NewOptions

func NewOptions() *options

NewOptions 创建 options

Types

type IMessage

type IMessage interface {
	xcontrol.ICallBack
	Marshal(message proto.Message) (data []byte, err error)
	Unmarshal(data []byte) (message proto.Message, err error)
	JsonUnmarshal(data []byte) (message proto.Message, err error)
	IsPassThrough() bool // 是否透传
}

type Message

type Message struct {
	xcontrol.ICallBack
	// contains filtered or unexported fields
}

func (*Message) Execute

func (p *Message) Execute() error

func (*Message) IsPassThrough

func (p *Message) IsPassThrough() bool

func (*Message) JsonUnmarshal

func (p *Message) JsonUnmarshal(data []byte) (message proto.Message, err error)

JsonUnmarshal 反序列化

message: 反序列化 得到的 消息

func (*Message) Marshal

func (p *Message) Marshal(message proto.Message) (data []byte, err error)

Marshal 序列化

func (*Message) Unmarshal

func (p *Message) Unmarshal(data []byte) (message proto.Message, err error)

Unmarshal 反序列化

message: 反序列化 得到的 消息

type Mgr

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

Mgr 管理器

func NewMgr

func NewMgr() *Mgr

func (*Mgr) Find

func (p *Mgr) Find(messageID uint32) IMessage

func (*Mgr) Register

func (p *Mgr) Register(messageID uint32, opts ...*options)

Register 注册消息

重复会 panic

func (*Mgr) Replace

func (p *Mgr) Replace(messageID uint32, opt *options)

Replace 替换/覆盖(Override)

配置错误会 panic