Struct Client 

pub struct Client { /* private fields */ }

MQTT 3.1.1 client.

Wraps ove_mqtt_client_t with automatic cleanup on drop.

Implementations

impl Client

pub fn new() -> Result<Self>

Create a new MQTT client via heap allocation (only in heap mode).

pub fn create(storage: &mut ClientStorage) -> Result<Self>

Create a client that works in both heap and zero-heap modes.

pub fn connect(&mut self, cfg: &Config<'_>, on_message: MessageFn) -> Result<()>

Connect to an MQTT broker.

on_message is called for each incoming publish (topic + payload).

Errors

Returns an error if the connection or MQTT handshake fails.

pub fn disconnect(&mut self)

Disconnect from the MQTT broker.

pub fn publish(&self, topic: &[u8], payload: &[u8], qos: Qos) -> Result<()>

Publish a message on a topic.

topic must be a null-terminated byte string.

Errors

Returns an error if the publish fails.

pub fn subscribe(&self, topic: &[u8], qos: Qos) -> Result<()>

Subscribe to a topic filter.

topic must be a null-terminated byte string.

Errors

Returns an error if the subscribe fails.

pub fn unsubscribe(&self, topic: &[u8]) -> Result<()>

Unsubscribe from a topic filter.

topic must be a null-terminated byte string.

Errors

Returns an error if the unsubscribe fails.

pub fn poll(&self, timeout_ms: u32) -> Result<()>

Process incoming packets and send keep-alive pings.

Must be called periodically (in a loop or from a timer callback).

Errors

Returns an error if the poll encounters a protocol or transport error.

Trait Implementations

impl Debug for Client

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for Client

fn drop(&mut self)

Executes the destructor for this type.

impl Send for Client