Struct PriorityQueue 

pub struct PriorityQueue { /* private fields */ }

Priority queue implementation

Implementations

impl PriorityQueue

pub fn new(config: PriorityQueueConfig) -> Self

pub fn enqueue(&self, message: PriorityMessage) -> Result<()>

Enqueue a message with priority

pub fn dequeue(&self) -> Option<PriorityMessage>

Dequeue the highest priority message

pub async fn dequeue_async(&self) -> Option<PriorityMessage>

Dequeue with async waiting

pub async fn dequeue_timeout( &self, timeout: Duration, ) -> Option<PriorityMessage>

Dequeue with timeout

pub fn peek(&self) -> Option<PriorityMessage>

Peek at the highest priority message without removing it

pub fn size(&self) -> usize

Get current queue size

pub fn is_empty(&self) -> bool

Check if queue is empty

pub fn stats(&self) -> PriorityQueueStats

Get queue statistics

pub fn requeue(&self, message: PriorityMessage) -> Result<()>

Requeue a failed message (with retry logic)

pub fn dead_letter_messages(&self) -> Vec<PriorityMessage>

Get dead letter queue contents

pub fn clear_dead_letter(&self) -> usize

Clear dead letter queue

Trait Implementations

impl Debug for PriorityQueue

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

Formats the value using the given formatter.