Struct MessageQueue 

pub struct MessageQueue { /* private fields */ }

A bounded, priority-ordered distributed message queue.

Implementations

impl MessageQueue

pub fn new(capacity: usize) -> Self

Create a new queue with the given capacity.

pub fn len(&self) -> usize

Number of messages currently in the queue.

pub fn is_empty(&self) -> bool

Return true when the queue contains no messages.

pub fn enqueue(&mut self, message: DistributedMessage) -> bool

Enqueue a message.

Returns false and increments the dropped counter when the queue is at capacity.

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

Dequeue the highest-priority message, or None if the queue is empty.

pub fn peek_priority(&self) -> Option<MessagePriority>

Peek at the priority of the next message without removing it.

pub fn enqueued_total(&self) -> u64

Total messages successfully enqueued since creation.

pub fn dropped_total(&self) -> u64

Total messages dropped due to capacity overflow.

pub fn drain_expired(&mut self, now: Instant) -> usize

Drain all expired messages (as of now) from the queue, returning the count of messages removed.

Trait Implementations

impl Debug for MessageQueue

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

Formats the value using the given formatter.