Struct LimitsManager 

pub struct LimitsManager { /* private fields */ }

Implementations

impl LimitsManager

pub fn new(config: LimitsConfig) -> Self

pub fn with_defaults() -> Self

pub fn set_server_maximum_packet_size(&mut self, size: u32)

pub fn reset_server_maximum_packet_size(&mut self)

pub fn set_client_maximum_packet_size(&mut self, size: u32)

pub fn effective_maximum_packet_size(&self) -> u32

The maximum packet size that may be sent on this connection.

An outbound packet is bounded solely by the server’s advertised Maximum Packet Size (from CONNACK). The client’s own Maximum Packet Size is the limit on packets it will receive, not what it may send, so it is never applied to outbound traffic here. When the server advertises no limit (or zero), the client’s configured maximum is used as the fallback ceiling. A returned value of 0 means “no limit”.

pub fn check_packet_size(&self, size: usize) -> Result<()>

Checks an outbound packet’s encoded size against effective_maximum_packet_size.

Errors

Returns PacketTooLarge if the size exceeds the effective maximum.

pub fn calculate_message_expiry( &self, expiry_interval: Option<u32>, ) -> Option<Instant>

pub fn is_message_expired(&self, expiry_time: Option<Instant>) -> bool

pub fn get_remaining_expiry(&self, expiry_time: Option<Instant>) -> Option<u32>

pub fn client_maximum_packet_size(&self) -> u32

pub fn server_maximum_packet_size(&self) -> Option<u32>

Trait Implementations

impl Debug for LimitsManager

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

Formats the value using the given formatter.