Module mqtt 

The C ABI for the MQTT transport.

These functions wrap [pamoja_mqtt] for callers that reach the SDK through the flat C boundary. Because that boundary has no async support, the crate owns a single multi-threaded Tokio runtime and each call blocks on it until the underlying async operation completes; a host that wants concurrency runs these calls on its own threads. The shared transport sits behind an async mutex, mirroring the Node and Python bindings so behavior matches across languages.

Structs

PamojaMqttClient

An opaque handle to an MQTT client transport.

PamojaMqttConfig

Connection settings for an MQTT client.

PamojaMqttMessage

An opaque handle to a message received from a subscribed topic.

Enums

PamojaQos

MQTT delivery guarantee, mirroring the protocol’s quality-of-service levels.

Functions

pamoja_mqtt_client_connect^⚠

Connects to the broker and starts the background event loop.

pamoja_mqtt_client_disconnect^⚠

Closes the connection and stops the background event loop.

pamoja_mqtt_client_free^⚠

Releases an MQTT client handle.

pamoja_mqtt_client_is_connected^⚠

Reports whether the client currently holds an active connection.

pamoja_mqtt_client_new^⚠

Creates a disconnected MQTT client from the given settings.

pamoja_mqtt_client_publish^⚠

Publishes a payload to a topic.

pamoja_mqtt_client_recv^⚠

Awaits the next message from any subscribed topic.

pamoja_mqtt_client_subscribe^⚠

Subscribes to a topic filter.

pamoja_mqtt_message_free^⚠

Releases a message handle.

pamoja_mqtt_message_payload^⚠

Returns a pointer to a message’s payload bytes.

pamoja_mqtt_message_payload_len^⚠

Returns the length in bytes of a message’s payload.

pamoja_mqtt_message_topic^⚠

Returns the topic a message was published to.