Struct PriorityQueue 

pub struct PriorityQueue<T> { /* private fields */ }

Multi-level priority queue

Implementations

impl<T> PriorityQueue<T>

pub fn new(config: PriorityConfig) -> Self

Create a new priority queue

pub fn with_default_config() -> Self

Create with default configuration

pub fn enqueue(&mut self, mail_id: MailId, item: T, priority: Priority)

Enqueue an item with a specific priority

pub fn dequeue(&mut self) -> Option<(MailId, T, Priority)>

Dequeue the next item based on priority (highest priority first)

pub fn peek(&self) -> Option<(&MailId, &T, Priority)>

Peek at the next item without removing it

pub fn len_for_priority(&self, priority: Priority) -> usize

Get the number of items in a specific priority queue

pub fn len(&self) -> usize

Get total number of items across all priorities

pub fn is_empty(&self) -> bool

Check if the queue is empty

pub fn remove(&mut self, mail_id: &MailId) -> Option<(T, Priority)>

Remove a specific item by mail ID

pub fn update_config(&self, config: PriorityConfig)

Update priority configuration

pub fn get_config(&self) -> PriorityConfig

Get current configuration

pub fn stats_for_priority(&self, priority: Priority) -> PriorityStats

Get statistics for a specific priority

pub fn mark_delivered(&self, priority: Priority)

Mark item as delivered (for statistics)

pub fn update_ready_delayed_stats( &self, priority: Priority, ready: usize, delayed: usize, )

Update ready/delayed counts for a priority

pub fn clear(&mut self)

Clear all queues

pub fn items_for_priority(&self, priority: Priority) -> Vec<&(MailId, T)>

Get all items for a specific priority

Trait Implementations

impl<T> Default for PriorityQueue<T>

fn default() -> Self

Returns the “default value” for a type.