linkmqtt

Documentation

Index

• func NewClient(cfg config.NorthMQTTConfig) (link.Link, error)
• func NewObserver() mqtt.Observer
• type MqttClient
  • func (m *MqttClient) Close() error
  • func (m *MqttClient) GetFailMsg() chan []byte
  • func (m *MqttClient) GetLinkID() string
  • func (m *MqttClient) Send(ctx *comctx.Context, data *link.SendMessage) error
  • func (m *MqttClient) SetFailMsg(fallMsg chan []byte)
  • func (m *MqttClient) SyncSend(ctx *comctx.Context, data []byte) error

Functions

func NewClient

func NewClient(cfg config.NorthMQTTConfig) (link.Link, error)

func NewObserver

func NewObserver() mqtt.Observer

Types

type MqttClient

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

func (*MqttClient) Close

func (m *MqttClient) Close() error

func (*MqttClient) GetFailMsg

func (m *MqttClient) GetFailMsg() chan []byte

func (*MqttClient) GetLinkID

func (m *MqttClient) GetLinkID() string

func (*MqttClient) Send

func (m *MqttClient) Send(ctx *comctx.Context, data *link.SendMessage) error

func (*MqttClient) SetFailMsg

func (m *MqttClient) SetFailMsg(fallMsg chan []byte)

func (*MqttClient) SyncSend

func (m *MqttClient) SyncSend(ctx *comctx.Context, data []byte) error