[−][src]Struct rumq_client::MqttOptions
Options to configure the behaviour of mqtt connection
Methods
impl MqttOptions
[src]
pub fn new<S: Into<String>, T: Into<String>>(
id: S,
host: T,
port: u16
) -> MqttOptions
[src]
id: S,
host: T,
port: u16
) -> MqttOptions
New mqtt options
pub fn broker_address(&self) -> (String, u16)
[src]
Broker address
pub fn set_last_will(&mut self, will: LastWill) -> &mut Self
[src]
pub fn last_will(&mut self) -> Option<LastWill>
[src]
pub fn set_ca(&mut self, ca: Vec<u8>) -> &mut Self
[src]
pub fn ca(&self) -> Option<Vec<u8>>
[src]
pub fn set_client_auth(&mut self, cert: Vec<u8>, key: Vec<u8>) -> &mut Self
[src]
pub fn client_auth(&self) -> Option<(Vec<u8>, Vec<u8>)>
[src]
pub fn set_alpn(&mut self, alpn: Vec<Vec<u8>>) -> &mut Self
[src]
pub fn alpn(&self) -> Option<Vec<Vec<u8>>>
[src]
pub fn set_keep_alive(&mut self, secs: u16) -> &mut Self
[src]
Set number of seconds after which client should ping the broker if there is no other data exchange
pub fn keep_alive(&self) -> Duration
[src]
Keep alive time
pub fn client_id(&self) -> String
[src]
Client identifier
pub fn set_max_packet_size(&mut self, sz: usize) -> &mut Self
[src]
Set packet size limit (in Kilo Bytes)
pub fn max_packet_size(&self) -> usize
[src]
Maximum packet size
pub fn set_clean_session(&mut self, clean_session: bool) -> &mut Self
[src]
clean_session = true
removes all the state from queues & instructs the broker
to clean all the client state when client disconnects.
When set false
, broker will hold the client state and performs pending
operations on the client when reconnection with same client_id
happens. Local queue state is also held to retransmit packets after reconnection.
pub fn clean_session(&self) -> bool
[src]
Clean session
pub fn set_credentials<S: Into<String>>(
&mut self,
username: S,
password: S
) -> &mut Self
[src]
&mut self,
username: S,
password: S
) -> &mut Self
Username and password
pub fn credentials(&self) -> Option<(String, String)>
[src]
Security options
pub fn set_notification_channel_capacity(
&mut self,
capacity: usize
) -> &mut Self
[src]
&mut self,
capacity: usize
) -> &mut Self
Set notification channel capacity
pub fn notification_channel_capacity(&self) -> usize
[src]
Notification channel capacity
pub fn set_request_channel_capacity(&mut self, capacity: usize) -> &mut Self
[src]
Set request channel capacity
pub fn request_channel_capacity(&self) -> usize
[src]
Request channel capacity
pub fn set_throttle(&mut self, duration: Duration) -> &mut Self
[src]
Enables throttling and sets outoing message rate to the specified 'rate'
pub fn throttle(&self) -> Duration
[src]
Outgoing message rate
pub fn set_inflight(&mut self, inflight: usize) -> &mut Self
[src]
Set number of concurrent in flight messages
pub fn inflight(&self) -> usize
[src]
Number of concurrent in flight messages
Trait Implementations
impl Clone for MqttOptions
[src]
fn clone(&self) -> MqttOptions
[src]
fn clone_from(&mut self, source: &Self)
1.0.0[src]
impl Debug for MqttOptions
[src]
Auto Trait Implementations
impl RefUnwindSafe for MqttOptions
impl Send for MqttOptions
impl Sync for MqttOptions
impl Unpin for MqttOptions
impl UnwindSafe for MqttOptions
Blanket Implementations
impl<T> Any for T where
T: 'static + ?Sized,
[src]
T: 'static + ?Sized,
impl<T> Borrow<T> for T where
T: ?Sized,
[src]
T: ?Sized,
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
T: ?Sized,
fn borrow_mut(&mut self) -> &mut T
[src]
impl<T> From<T> for T
[src]
impl<T, U> Into<U> for T where
U: From<T>,
[src]
U: From<T>,
impl<T> ToOwned for T where
T: Clone,
[src]
T: Clone,
type Owned = T
The resulting type after obtaining ownership.
fn to_owned(&self) -> T
[src]
fn clone_into(&self, target: &mut T)
[src]
impl<T, U> TryFrom<U> for T where
U: Into<T>,
[src]
U: Into<T>,
type Error = Infallible
The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
impl<T, U> TryInto<U> for T where
U: TryFrom<T>,
[src]
U: TryFrom<T>,