Struct svc_agent::mqtt::AgentConfig

pub struct AgentConfig { /* fields omitted */ }

Agent configuration.

Options

• uri – MQTT broker URI (required).
• clean_session – whether to start a clean session or continue the persisted session. Default: true.
• keep_alive_interval – keep alive time to ping the broker. Default: 30 sec.
• reconnect_interval – reconnection attempts interval, never reconnect if absent. Default: never reconnect.
• outgoing_message_queue_size – maximum messages in-flight. Default: 100.
• incoming_message_queue_size – notification channel capacity. Default: 10.
• max_message_size – maximum message size in bytes. Default: 256 * 1024.
• password – MQTT broker password.

Methods

impl AgentConfig

pub fn set_password(&mut self, value: &str) -> &mut Self

Sets password field to the config.

Use if you don't store the password in the config file but in an environment variable, somewhere else or generate an access token in runtime.

Trait Implementations

impl Clone for AgentConfig

fn clone(&self) -> AgentConfig

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for AgentConfig

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AgentConfig

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error> where
    __D: Deserializer<'de>, 

Deserialize this value from the given Serde deserializer.