mqtt

Documentation

Overview

Package mqtt implements the MQTT provider using the mqtt driver.

Index

• func OpenConnection(ctx context.Context, settings *ttnpb.ApplicationPubSub_MQTT, ...) (*provider.Connection, error)
• 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 OpenConnection

func OpenConnection(ctx context.Context, settings *ttnpb.ApplicationPubSub_MQTT, topics provider.Topics) (*provider.Connection, error)

OpenConnection opens a MQTT connection using the given settings.

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.