mqtt

Documentation

Index

• func Connect(serverURL string) (mqtt.Client, error)
• func Publish(mqttClient mqtt.Client, topic string, qos byte, retained bool, ...) error
• func Subscribe(mqttClient mqtt.Client, topic string, qos byte, cb mqtt.MessageHandler) error
• func Unsubscribe(mqttClient mqtt.Client, topics []string) error

Functions

func Connect

func Connect(serverURL string) (mqtt.Client, error)

func Publish

func Publish(mqttClient mqtt.Client, topic string, qos byte, retained bool, value interface{}) error

Publishes a given value to the the broker at the given topic. Non-strings are converted to their string representations.

func Subscribe

func Subscribe(mqttClient mqtt.Client, topic string, qos byte, cb mqtt.MessageHandler) error

func Unsubscribe

func Unsubscribe(mqttClient mqtt.Client, topics []string) error