common

Documentation

Index

• type MessageContainer
• type MessageTable
  • func NewMessageTable() *MessageTable
  • func (slf *MessageTable) Clean()
  • func (slf *MessageTable) Get(id uint16) (message.Message, error)
  • func (slf *MessageTable) NewID() uint16
  • func (slf *MessageTable) Register(id uint16, msg message.Message, opaque interface{})
  • func (slf *MessageTable) Register2(id uint16, msg message.Message, count int, opaque interface{})
  • func (slf *MessageTable) Remove(id uint16)
  • func (slf *MessageTable) Unref(id uint16)
  • func (slf *MessageTable) WithOnFinish(callback func(uint16, message.Message, interface{}))
• type Subscription

Types

type MessageContainer

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

MessageContainer 消息内容句柄

type MessageTable

type MessageTable struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

MessageTable 消息

func NewMessageTable

func NewMessageTable() *MessageTable

NewMessageTable 创建一个消息确认表

func (*MessageTable) Clean

func (slf *MessageTable) Clean()

Clean 清除

func (*MessageTable) Get

func (slf *MessageTable) Get(id uint16) (message.Message, error)

Get 返回一个消息

func (*MessageTable) NewID

func (slf *MessageTable) NewID() uint16

NewID 创建一个新的ID

func (*MessageTable) Register

func (slf *MessageTable) Register(id uint16, msg message.Message, opaque interface{})

Register 注册一个消息

func (*MessageTable) Register2

func (slf *MessageTable) Register2(id uint16, msg message.Message, count int, opaque interface{})

Register2 注册一个消息并设置计数器

func (*MessageTable) Remove

func (slf *MessageTable) Remove(id uint16)

Remove 移除一个消息

func (*MessageTable) Unref

func (slf *MessageTable) Unref(id uint16)

Unref 取消一个消息的引用

func (*MessageTable) WithOnFinish

func (slf *MessageTable) WithOnFinish(callback func(uint16, message.Message, interface{}))

WithOnFinish 设置消息完成回掉调函数

type Subscription

type Subscription struct {
	Client string
	Topic  string
	Qos    byte
}