Struct RetryQueue 

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

Thread-safe retry queue for items of type T.

Implementations

impl<T: Clone> RetryQueue<T>

pub fn new(config: RetryConfig) -> Self

Create a new retry queue with the given configuration.

pub fn enqueue(&self, item: T, attempts: u32) -> bool

Enqueue an item for retry. If attempts exceeds max_attempts, the item is NOT enqueued and false is returned (dead-letter).

pub fn drain_ready(&self) -> Vec<RetryEntry<T>>

Dequeue all items that are ready for retry. Clears them from the queue.

pub fn len(&self) -> usize

Peek at the number of items in the queue.

pub fn is_empty(&self) -> bool

Is the queue empty?

pub fn config(&self) -> &RetryConfig

Get the configuration.