mqtt

Documentation

Index

• func CreateMQTTClient(config configuration.MQTTConfig) models.MQTTClient
• type MQTT
  • func (m *MQTT) Publish(topic string, message string, qos byte)
  • func (m *MQTT) Start(api *models.API)
  • func (m *MQTT) Stop()

Functions

func CreateMQTTClient

func CreateMQTTClient(config configuration.MQTTConfig) models.MQTTClient

CreateMQTTClient creates a new MQTT client

Types

type MQTT

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

MQTT is the implementation of the MQTT client

func (*MQTT) Publish

func (m *MQTT) Publish(topic string, message string, qos byte)

Publish a message on a topic

func (*MQTT) Start

func (m *MQTT) Start(api *models.API)

Start running the MQTT client

func (*MQTT) Stop

func (m *MQTT) Stop()

Stop the MQTT client