Struct MqttConfig 

pub struct MqttConfig { /* private fields */ }

Connection settings for an MqttTransport.

Construct with MqttConfig::new and refine with the chained setters; every field has a sensible default so only the broker address and client id are required.

Implementations

impl MqttConfig

pub fn new( client_id: impl Into<String>, host: impl Into<String>, port: u16, ) -> Self

Creates a configuration for the given client id and broker address.

Arguments

• client_id - the MQTT client identifier presented to the broker.
• host - the broker hostname or IP address.
• port - the broker TCP port, conventionally 1883 for plaintext MQTT.

Returns

A configuration with a 30-second keep-alive, a request capacity of 64, and a default quality of service of QualityOfService::AtLeastOnce.

pub fn keep_alive(self, interval: Duration) -> Self

Sets the keep-alive interval used to hold the connection open.

Arguments

• interval - how often the client pings the broker when otherwise idle.

Returns

The updated configuration, for chaining.

pub fn capacity(self, capacity: usize) -> Self

Sets the bound on outstanding client requests buffered toward the broker.

Arguments

• capacity - the request channel capacity; values below one are clamped to one.

Returns

The updated configuration, for chaining.

pub fn qos(self, qos: QualityOfService) -> Self

Sets the default quality of service for publishes and subscriptions.

Arguments

• qos - the delivery guarantee applied by send and subscribe.

Returns

The updated configuration, for chaining.

Trait Implementations

impl Clone for MqttConfig

fn clone(&self) -> MqttConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for MqttConfig

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

Formats the value using the given formatter.