Struct PeerPriorityQueue 

pub struct PeerPriorityQueue {
    pub urgent: Vec<QueuedMessage>,
    pub normal: Vec<QueuedMessage>,
    pub background: Vec<QueuedMessage>,
    pub peer_counts: HashMap<String, usize>,
    pub current_bytes: u64,
    pub config: QueueConfig,
    pub stats: QueueStats,
}

Multi-level priority queue for outbound peer messages.

See the module documentation for a full description of the backpressure strategy and dequeue ordering.

Fields

urgent: Vec<QueuedMessage>

FIFO sub-queue for MessagePriority::Urgent messages.

normal: Vec<QueuedMessage>

FIFO sub-queue for MessagePriority::Normal messages.

background: Vec<QueuedMessage>

FIFO sub-queue for MessagePriority::Background messages.

peer_counts: HashMap<String, usize>

Current pending message count keyed by peer identifier.

current_bytes: u64

Sum of payload_bytes for all currently queued messages.

config: QueueConfig

Configuration controlling limits and weights.

stats: QueueStats

Cumulative statistics.

Implementations

impl PeerPriorityQueue

pub fn new(config: QueueConfig) -> Self

Create a new queue with the supplied configuration.

pub fn enqueue(&mut self, msg: QueuedMessage) -> bool

Attempt to enqueue msg.

Returns true when the message was accepted, false when it was dropped because either the global byte budget or the per-peer message cap would be exceeded.

pub fn dequeue(&mut self) -> Option<QueuedMessage>

Dequeue the highest-priority available message.

Priority order is Urgent → Normal → Background. Returns None when all sub-queues are empty.

pub fn dequeue_n(&mut self, n: usize) -> Vec<QueuedMessage>

Dequeue up to n messages, returning however many were available.

pub fn len(&self) -> usize

Total number of messages across all sub-queues.

pub fn is_empty(&self) -> bool

Returns true when all sub-queues are empty.

pub fn stats(&self) -> &QueueStats

Reference to the current queue statistics.

pub fn remove_peer(&mut self, peer_id: &str) -> usize

Remove all pending messages for peer_id.

Returns the number of messages removed. Updates current_bytes, peer_counts, and the relevant stats fields.