Crate beluga_mqtt

Crate beluga_mqtt 

Modulesยง

error ๐Ÿ”’
manager ๐Ÿ”’
subscriber ๐Ÿ”’

Structsยง

MqttClient
MqttClientBuilder
A builder for creating an MqttClient with specific configurations.
MqttContext ๐Ÿ”’
A struct that holds the context for an MQTT connection, including a subscriber manager and any connection errors that have occurred.
OwnedSubscriber
Represents an MQTT subscriber that owns the underlying subscriber and tracks the subscribed topics. When the OwnedSubscriber is dropped, it will unsubscribe from all the subscribed topics.
PollContext ๐Ÿ”’
It is a struct that holds the necessary components for polling the MQTT broker.
Publish
Publish packet
Subscriber
Represents an MQTT subscriber that can receive Publish messages.

Enumsยง

Error
An error that can occur when using the Beluga MQTT client.
QoS
Quality of service

Constantsยง

DEFAULT_CONNECT_TIMEOUT ๐Ÿ”’
DEFAULT_MAX_RECONNECT_DELAY ๐Ÿ”’
DEFAULT_MIN_RECONNECT_DELAY ๐Ÿ”’

Functionsยง

poll ๐Ÿ”’
Asynchronous function that handles polling the MQTT event loop.
process_event ๐Ÿ”’
Processes an MQTT event.
process_packet ๐Ÿ”’
Processes a received MQTT packet.
resubscribe ๐Ÿ”’
warn_if_topics_scheduled ๐Ÿ”’
Warns the user if any of the new topics being subscribed to are already scheduled for unsubscription.

Type Aliasesยง

Receiver ๐Ÿ”’
Result
Sender ๐Ÿ”’