Struct PendingQueueConfig 

pub struct PendingQueueConfig {
    pub max_pending_per_peer: usize,
    pub max_pending_global: usize,
    pub max_pending_bytes_per_peer: usize,
    pub max_pending_bytes_global: usize,
    pub pending_ttl_ms: u64,
    pub overflow_policy: OverflowPolicy,
}

Configuration for inbound encrypted messages received before session readiness.

Fields

max_pending_per_peer: usize

Maximum number of pending encrypted messages per peer.

max_pending_global: usize

Maximum number of pending encrypted messages across all peers.

max_pending_bytes_per_peer: usize

Maximum total payload bytes (content plus binary content) queued per peer.

Encrypted media chunks are queued whole while the sender’s session is not yet ready, so the count limits alone would admit up to max_pending_per_peer × chunk-size bytes of ciphertext. The default (4 MB) covers the largest legitimate pre-session backlog: 2 concurrent transfers × 8 in-flight chunks × 256 KB internet chunks.

max_pending_bytes_global: usize

Maximum total payload bytes queued across all peers. The default (32 MB) bounds worst-case queue memory on mobile devices regardless of how many peers are mid-establishment.

pending_ttl_ms: u64

Time-to-live for pending encrypted messages in milliseconds.

overflow_policy: OverflowPolicy

Overflow policy when queue limits are reached.

Trait Implementations

impl Clone for PendingQueueConfig

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PendingQueueConfig

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

Formats the value using the given formatter.

impl Default for PendingQueueConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for PendingQueueConfig

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for PendingQueueConfig

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.