Struct Config 

pub struct Config {

    pub client_id: ClientId,
    broker_url: BrokerUrl,
    pub persistence_dir: Option<Box<Path>>,
    pub tls: Config,
    pub subscription_buffer_size: usize,
    pub max_buffered_messages: usize,
    pub command_buffer_size: usize,
    pub connect: Connect,
    pub subscribe_timeout: Duration,
    pub disconnect_timeout: Duration,
    pub keep_alive_interval: Duration,
    pub max_inflight: usize,
    pub session_expiry_interval: Duration,
}

Fields

client_id: ClientId

broker_url: BrokerUrl

persistence_dir: Option<Box<Path>>

tls: Config

subscription_buffer_size: usize

max_buffered_messages: usize

command_buffer_size: usize

connect: Connect

subscribe_timeout: Duration

disconnect_timeout: Duration

keep_alive_interval: Duration

max_inflight: usize

session_expiry_interval: Duration

Implementations

impl Config

pub fn new(broker_url: BrokerUrl) -> Self

Creates a new Config with the given broker URL and TLS configuration.

pub fn has_client_id(&self) -> bool

pub fn set_default_client_id(&mut self, client_id: String)

pub async fn build(self) -> Result<Mqtt, Error>

pub(crate) fn apply_defaults(&mut self)

pub(crate) fn create_client( &self, client_id: String, ) -> Result<AsyncClient, Error>

pub(crate) async fn create_connect_opts(&self) -> Result<ConnectOptions, Error>

Trait Implementations

impl Clone for Config

fn clone(&self) -> Config

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'de> Deserialize<'de> for Config

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.