Struct RetryQueue 

pub struct RetryQueue { /* private fields */ }

Retry queue for managing message retries with exponential backoff.

Implementations

impl RetryQueue

pub fn new() -> Self

Creates a new retry queue with default configuration.

pub fn with_config(config: RetryConfig) -> Self

Creates a new retry queue with custom configuration.

pub fn enqueue( &mut self, message: Message, retry_count: u32, ) -> Option<DateTime<Utc>>

Adds a message to the retry queue.

The retry queue is a pure scheduling mechanism — it does not enforce a retry limit. ACK-level retry limits are enforced by the ACK manager in the protocol layer.

Duplicate messages (same ID already in queue) are silently ignored.

Arguments

• message - The message to queue for retry
• retry_count - Current retry count (used for backoff calculation)

Returns

The absolute time the retry is scheduled for, or None if the message was already queued (nothing was scheduled).

pub fn enqueue_with_delay( &mut self, message: Message, retry_count: u32, delay_ms: u64, ) -> Option<DateTime<Utc>>

Adds a message to the retry queue with an explicit delay, bypassing the backoff formula.

Used for reachability probes toward peers an authoritative relay verdict reported unreachable, where the interval is driven by per-peer escalation rather than this message’s retry count.

Duplicate messages (same ID already in queue) are silently ignored; None means nothing was scheduled.

pub fn dequeue_ready(&mut self) -> Option<RetryEntry>

Dequeues the next message that is ready for retry.

Returns

Returns Some(RetryEntry) if a message is ready, None otherwise.

pub fn peek_ready(&self) -> Vec<&RetryEntry>

Gets all messages ready for retry without removing them.

pub fn remove(&mut self, message_id: &str) -> bool

Removes a message from the queue (e.g., after successful delivery).

pub fn cleanup_expired(&mut self) -> usize

Cleans up expired messages that exceeded their max lifetime.

Returns

Returns the number of expired messages removed.

pub fn len(&self) -> usize

Gets the number of messages in the queue.

pub fn is_empty(&self) -> bool

Checks if the queue is empty.

pub fn contains(&self, message_id: &str) -> bool

Checks if a message is in the queue.

pub fn drain_all(&mut self) -> Vec<RetryEntry>

Drains all entries from the queue, ignoring retry_at timing.

Returns entries in priority order (earliest retry_at first, then highest message priority). Used for immediate flush when transport becomes available.

pub fn time_until_next_retry(&self) -> Option<Duration>

Gets the time until the next retry is ready.

Returns

Returns Some(Duration) if there are pending retries, None if empty.

pub fn stats(&self) -> RetryQueueStats

Gets statistics about the retry queue.

Trait Implementations

impl Default for RetryQueue

fn default() -> Self

Returns the “default value” for a type.