mqtt

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