Struct DeferredQueue 

pub struct DeferredQueue { /* private fields */ }

Queue of deferred entries awaiting retry.

Implementations

impl DeferredQueue

pub fn new(capacity: usize) -> Self

Create a new deferred queue with the given capacity.

pub fn enqueue( &mut self, peer_id: u64, user_id: u64, tenant_id: u64, delta: Vec<u8>, collection: String, constraint_name: String, attempt: u32, max_retries: u32, now_ms: u64, first_retry_after_ms: u64, ttl_secs: u64, ) -> u64

Enqueue a deferred entry.

Arguments

• peer_id — the peer that produced the delta
• delta — the raw delta bytes
• collection — the target collection
• constraint_name — the constraint that was violated
• attempt — current attempt number (usually 0 for first deferral)
• max_retries — maximum retries allowed
• now_ms — current time in milliseconds since epoch
• first_retry_after_ms — milliseconds to wait before first retry
• ttl_secs — seconds from now until this entry expires

pub fn poll_ready(&mut self, now_ms: u64) -> Vec<DeferredEntry>

Poll for entries ready for retry.

Returns all entries whose next_retry_ms <= now_ms.

pub fn expire(&mut self, now_ms: u64) -> Vec<DeferredEntry>

Expire entries past their TTL deadline.

Returns all entries whose ttl_deadline_ms <= now_ms. These should be routed to the DLQ as unrecoverable.

pub fn enqueue_retry(&mut self, entry: DeferredEntry, now_ms: u64)

Re-enqueue an entry for retry after the next backoff interval.

The backoff is calculated as: base_ms * 2^attempt, capped at 30s.

pub fn len(&self) -> usize

Number of pending deferred entries.

pub fn is_empty(&self) -> bool

pub fn capacity(&self) -> usize

Capacity of the queue.

pub fn clear(&mut self)

Clear all entries.

Trait Implementations

impl Debug for DeferredQueue

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

Formats the value using the given formatter.