mqtt

Documentation

Index

• func NewObserver(msgChs chan *models.MsgChan, log *log.Logger) mqtt.Observer
• type Client
  • func NewMqtt(ctx dm.Context, cfg config.Config) (*Client, error)
  • func (m *Client) Close() error
  • func (m *Client) Offline(ctx *comctx.Context, node string, info *dm.DeviceInfo) error
  • func (m *Client) Online(ctx *comctx.Context, node string, info *dm.DeviceInfo) error
  • func (m *Client) ReportDeviceProperties(ctx *comctx.Context, node string, info *dm.DeviceInfo, report v1.Report, ...) error
  • func (m *Client) Start(ch chan *models.MsgChan) error

Functions

func NewObserver

func NewObserver(msgChs chan *models.MsgChan, log *log.Logger) mqtt.Observer

Types

type Client

type Client struct {
	*mqtt.Client
	// contains filtered or unexported fields
}

func NewMqtt

func NewMqtt(ctx dm.Context, cfg config.Config) (*Client, error)

func (*Client) Close

func (m *Client) Close() error

func (*Client) Offline

func (m *Client) Offline(ctx *comctx.Context, node string, info *dm.DeviceInfo) error

Online 报告设备离线状态

func (*Client) Online

func (m *Client) Online(ctx *comctx.Context, node string, info *dm.DeviceInfo) error

Online 报告设备在线状态

func (*Client) ReportDeviceProperties

func (m *Client) ReportDeviceProperties(ctx *comctx.Context, node string, info *dm.DeviceInfo, report v1.Report, topic string) error

ReportDeviceProperties 召测使用系统mqtt

func (*Client) Start

func (m *Client) Start(ch chan *models.MsgChan) error