mqtt

Documentation

Overview

Package mqtt implements the MQTT provider using the mqtt driver.

Index

• func OpenSubscription(client mqtt.Client, topicName string, timeout time.Duration, qos byte) (*pubsub.Subscription, error)
• func OpenTopic(client mqtt.Client, topicName string, timeout time.Duration, qos byte) (*pubsub.Topic, error)

Functions

func OpenSubscription

func OpenSubscription(client mqtt.Client, topicName string, timeout time.Duration, qos byte) (*pubsub.Subscription, error)

OpenSubscription returns a *pubsub.Subscription that subscribes to the given topic name with the given MQTT client.

func OpenTopic

func OpenTopic(client mqtt.Client, topicName string, timeout time.Duration, qos byte) (*pubsub.Topic, error)

OpenTopic returns a *pubsub.Topic that publishes to the given topic name with the given MQTT client.