mqtt

Documentation

Index

• func NewMqttClientWrapper(props map[string]interface{}) (clients.ClientWrapper, error)
• type MQTTClient
  • func (ms *MQTTClient) CfgValidate(props map[string]interface{}) error
  • func (ms *MQTTClient) Connect(connHandler MQTT.OnConnectHandler, lostHandler MQTT.ConnectionLostHandler) error
  • func (ms *MQTTClient) Disconnect() error
  • func (ms *MQTTClient) Publish(topic string, qos byte, retained bool, message []byte) error
  • func (ms *MQTTClient) Subscribe(topic string, qos byte, handler MQTT.MessageHandler) error
• type MQTTConnectionConfig

Functions

func NewMqttClientWrapper

func NewMqttClientWrapper(props map[string]interface{}) (clients.ClientWrapper, error)

Types

type MQTTClient

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

func (*MQTTClient) CfgValidate

func (ms *MQTTClient) CfgValidate(props map[string]interface{}) error

func (*MQTTClient) Connect

func (ms *MQTTClient) Connect(connHandler MQTT.OnConnectHandler, lostHandler MQTT.ConnectionLostHandler) error

func (*MQTTClient) Disconnect

func (ms *MQTTClient) Disconnect() error

func (*MQTTClient) Publish

func (ms *MQTTClient) Publish(topic string, qos byte, retained bool, message []byte) error

func (*MQTTClient) Subscribe

func (ms *MQTTClient) Subscribe(topic string, qos byte, handler MQTT.MessageHandler) error

type MQTTConnectionConfig

type MQTTConnectionConfig struct {
	Server   string `json:"server"`
	PVersion string `json:"protocolVersion"`
	ClientId string `json:"clientid"`
	Uname    string `json:"username"`
	Password string `json:"password"`
}