Struct DefaultFitter 

pub struct DefaultFitter { /* private fields */ }

Implementations

impl DefaultFitter

pub fn new( conn_info: Arc<ConnectInfo>, _id: Id, listen_cfg: ListenerConfig, ) -> Self

Trait Implementations

impl Clone for DefaultFitter

fn clone(&self) -> DefaultFitter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Fitter for DefaultFitter

fn keep_alive(&self, keep_alive: &mut u16) -> Result<u16>

keep_alive - is client input value, unit: seconds

fn max_mqueue_len(&self) -> usize

Maximum length of message queue, default value: 1000

fn mqueue_rate_limit(&self) -> (NonZeroU32, Duration)

Pop up message speed from message queue, the number of pop-up messages from the queue within a specified time, which can effectively control the message flow rate, default value: 100 / 10s

fn max_inflight(&self) -> NonZeroU16

max inflight

fn session_expiry_interval(&self, d: Option<&Disconnect>) -> Duration

session expiry interval

fn message_expiry_interval(&self, publish: &Publish) -> Duration

message expiry interval

fn max_client_topic_aliases(&self) -> u16

client topic alias maximum, C -> S(Max Limit)

fn max_server_topic_aliases(&self) -> u16

server topic alias maximum, S(Max Limit) -> C