safemqtt

Documentation

Index

• func LogMQTTMessageHandler(name string, handler ErrMQTTMessageHandler) mqtt.MessageHandler
• type Client
  • func InitMQTTClient(cfg *config.MQTT, id string) (Client, error)
• type ErrMQTTMessageHandler

Functions

func LogMQTTMessageHandler

func LogMQTTMessageHandler(name string, handler ErrMQTTMessageHandler) mqtt.MessageHandler

Types

type Client

type Client interface {
	SafePublish(topic string, qos byte, retained bool, payload interface{}) mqtt.Token
	SafeSubscribe(topic string, qos byte, callback mqtt.MessageHandler) mqtt.Token
	SafeUnsubscribe(topics ...string) mqtt.Token
	IsConnected() bool
}

Client is bridge between our app and MQTT

func InitMQTTClient

func InitMQTTClient(cfg *config.MQTT, id string) (Client, error)

type ErrMQTTMessageHandler

type ErrMQTTMessageHandler func(client mqtt.Client, msg mqtt.Message) error