mqttx

Documentation

Index

• type Conf
• type MqtMsg
• type MqttX
  • func Create(conf Conf, defaultPublishHandler MsgHandler, onConnectHandler OnConnectHandler, ...) (*MqttX, error)
  • func QuickCreate(conf Conf) (*MqttX, error)
  • func (mx *MqttX) Disconnect(quiesce uint)
  • func (mx *MqttX) Publish(msg MqtMsg)
  • func (mx *MqttX) Subscribe(msg MqtMsg, callback MsgHandler)
  • func (mx *MqttX) Unsubscribe(topics ...string) error
• type MsgHandler
• type OnConnectHandler
• type OnConnectionLostHandler

Types

type Conf

type Conf struct {
	Host     string `json:"host"`
	Port     int    `json:"port"`
	Username string `json:"username,optional"`
	Password string `json:"password,optional"`
	ClientId string `json:"clientId,optional"`
}

type MqtMsg

type MqtMsg struct {
	Topic     string
	Duplicate bool
	Qos       byte
	Retained  bool
	MessageID uint16
	Payload   []byte
	Ack       func()
}

type MqttX

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

func Create

func Create(conf Conf,
	defaultPublishHandler MsgHandler,
	onConnectHandler OnConnectHandler,
	onConnectionLostHandler OnConnectionLostHandler,
) (*MqttX, error)

func QuickCreate

func QuickCreate(conf Conf) (*MqttX, error)

func (*MqttX) Disconnect

func (mx *MqttX) Disconnect(quiesce uint)

func (*MqttX) Publish

func (mx *MqttX) Publish(msg MqtMsg)

func (*MqttX) Subscribe

func (mx *MqttX) Subscribe(msg MqtMsg, callback MsgHandler)

func (*MqttX) Unsubscribe

func (mx *MqttX) Unsubscribe(topics ...string) error

type MsgHandler

type MsgHandler func(MqtMsg)

type OnConnectHandler

type OnConnectHandler func()

type OnConnectionLostHandler

type OnConnectionLostHandler func(error)