Struct PendingQueueMetrics 

pub struct PendingQueueMetrics {
    pub pending_messages_received_total: u64,
    pub pending_messages_evicted_total: u64,
    pub pending_messages_dropped_overflow_total: u64,
    pub pending_messages_expired_total: u64,
    pub pending_messages_eviction_failures_total: u64,
    pub pending_queue_invariant_violations_total: u64,
    pub pending_messages_current: usize,
    pub pending_bytes_current: usize,
    pub pending_messages_per_peer: HashMap<String, usize>,
}

Counters and gauges for pending encrypted message queue pressure.

Fields

pending_messages_received_total: u64

Total encrypted messages received before session readiness.

pending_messages_evicted_total: u64

Total queued messages evicted from pending storage.

pending_messages_dropped_overflow_total: u64

Total messages dropped due to overflow policy decisions.

pending_messages_expired_total: u64

Total pending messages expired due to TTL.

pending_messages_eviction_failures_total: u64

Number of failed eviction attempts while enforcing hard bounds.

pending_queue_invariant_violations_total: u64

Number of detected pending queue invariant violations.

pending_messages_current: usize

Current number of messages in pending queues across all peers.

pending_bytes_current: usize

Current payload bytes (content plus binary content) queued across all peers.

pending_messages_per_peer: HashMap<String, usize>

Current per-peer pending queue sizes.

Trait Implementations

impl Clone for PendingQueueMetrics

fn clone(&self) -> PendingQueueMetrics

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for PendingQueueMetrics

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

Formats the value using the given formatter.

impl Default for PendingQueueMetrics

fn default() -> PendingQueueMetrics

Returns the “default value” for a type.