Struct DeadLetterQueue 

pub struct DeadLetterQueue { /* private fields */ }

In-memory dead-letter queue for shed pipeline requests.

Stores up to capacity most-recent dropped requests in a ring buffer. When full, the oldest entry is evicted to make room for the newest.

Thread-safe via an internal Mutex. Clone is cheap — all clones share the same underlying ring.

Implementations

impl DeadLetterQueue

pub fn new(capacity: usize) -> Self

Create a new DeadLetterQueue with the given ring-buffer capacity.

Panics

This function does not panic.

pub fn push(&self, req: DroppedRequest)

Push a dropped request into the queue. Evicts the oldest entry if full.

Panics

This function does not panic. If the internal mutex is poisoned it is recovered automatically and a warning is logged.

pub fn drain(&self) -> Vec<DroppedRequest>

Drain all queued entries and return them, clearing the queue.

Panics

This function does not panic. If the internal mutex is poisoned it is recovered automatically and a warning is logged.

pub fn len(&self) -> usize

Return the number of entries currently in the queue.

Panics

This function does not panic. If the internal mutex is poisoned it is recovered automatically and a warning is logged.

pub fn is_empty(&self) -> bool

Return true if the queue contains no entries.

Panics

This function does not panic. If the internal mutex is poisoned it is recovered automatically and a warning is logged.

pub fn capacity(&self) -> usize

Return the maximum number of entries this queue can hold before evicting.

Panics

This function does not panic.

pub fn peek(&self) -> Vec<DroppedRequest>

Return a snapshot of all queued entries without removing them.

Unlike drain, this does not clear the queue. The snapshot is a clone taken under the lock; the queue continues to operate normally while the returned Vec is used.

Panics

This function does not panic. If the internal mutex is poisoned it is recovered automatically and a warning is logged.

Trait Implementations

impl Clone for DeadLetterQueue

fn clone(&self) -> DeadLetterQueue

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.