Struct BoundedQueue 

pub struct BoundedQueue { /* private fields */ }

Bounded queue with blocking operations.

Implementations

impl BoundedQueue

pub fn new(capacity: usize) -> Self

Create a new bounded queue.

pub fn enqueue_timeout( &self, envelope: MessageEnvelope, timeout: Duration, ) -> Result<()>

Blocking enqueue with timeout.

pub fn dequeue_timeout(&self, timeout: Duration) -> Result<MessageEnvelope>

Blocking dequeue with timeout.

Trait Implementations

impl MessageQueue for BoundedQueue

fn capacity(&self) -> usize

Get the queue capacity.

fn len(&self) -> usize

Get current queue size.

fn try_enqueue(&self, envelope: MessageEnvelope) -> Result<()>

Try to enqueue a message envelope.

fn try_dequeue(&self) -> Result<MessageEnvelope>

Try to dequeue a message envelope.

fn stats(&self) -> QueueStats

Get queue statistics.

fn reset_stats(&self)

Reset queue statistics.

fn is_empty(&self) -> bool

Check if queue is empty.

fn is_full(&self) -> bool

Check if queue is full.