c1_mqttPublish

Documentation

Index

• Variables
• func NewPublisher(mc mqtt.Client) *publisher
• func PublishMain()
• type ProxyMemStore
  • func (p *ProxyMemStore) All() []string
  • func (p *ProxyMemStore) Close()
  • func (p *ProxyMemStore) Del(key string)
  • func (p *ProxyMemStore) Get(key string) packets.ControlPacket
  • func (p *ProxyMemStore) Open()
  • func (p *ProxyMemStore) Put(key string, message packets.ControlPacket)
  • func (p *ProxyMemStore) Reset()
• type PublishBootArgs
  • func (PublishBootArgs) ExecFunc() func()
  • func (PublishBootArgs) FlagDefine() func(xflag *flag.FlagSet)
  • func (receiver *PublishBootArgs) String() string

Variables

var (
	XPublishBootargs = new(PublishBootArgs)
)

Functions

func NewPublisher

func NewPublisher(mc mqtt.Client) *publisher

func PublishMain

func PublishMain()

向mqtt服务器订阅监控某一个客户端消息,等待客户端状态消息上报.

Types

type ProxyMemStore

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

func (*ProxyMemStore) All

func (p *ProxyMemStore) All() []string

func (*ProxyMemStore) Close

func (p *ProxyMemStore) Close()

func (*ProxyMemStore) Del

func (p *ProxyMemStore) Del(key string)

func (*ProxyMemStore) Get

func (p *ProxyMemStore) Get(key string) packets.ControlPacket

func (*ProxyMemStore) Open

func (p *ProxyMemStore) Open()

func (*ProxyMemStore) Put

func (p *ProxyMemStore) Put(key string, message packets.ControlPacket)

func (*ProxyMemStore) Reset

func (p *ProxyMemStore) Reset()

type PublishBootArgs

type PublishBootArgs struct {
	MqttHostAddr string
	MqttHostPort int
	MqttTopic    string
	MqttQos      byte
}

func (PublishBootArgs) ExecFunc

func (PublishBootArgs) ExecFunc() func()

func (PublishBootArgs) FlagDefine

func (PublishBootArgs) FlagDefine() func(xflag *flag.FlagSet)

func (*PublishBootArgs) String

func (receiver *PublishBootArgs) String() string