Struct DlqReplayScheduler 

pub struct DlqReplayScheduler {
    pub replayed_total: Arc<AtomicU64>,
    pub aged_out_total: Arc<AtomicU64>,
    /* private fields */
}

Dead-letter queue replay scheduler.

Wraps the pipeline’s dead-letter concept and adds:

• replay_all — re-inject every eligible entry with exponential backoff between sends.
• replay_by_session — replay only entries belonging to a specific session.
• age_out — drop entries older than a given Duration.

DlqReplayScheduler is Clone + Send + Sync. All clones share the same internal queue.

Prometheus counters

• dlq_replayed_total — incremented on each successful re-injection.
• dlq_aged_out_total — incremented on each eviction by age_out.

Fields

replayed_total: Arc<AtomicU64>

Total entries replayed across the lifetime of this scheduler.

aged_out_total: Arc<AtomicU64>

Total entries aged out across the lifetime of this scheduler.

Implementations

impl DlqReplayScheduler

pub fn new() -> Self

Create a new empty DlqReplayScheduler.

Panics

This function does not panic.

pub fn push(&self, entry: ReplayEntry)

Push a new ReplayEntry into the scheduler queue.

Panics

This function does not panic.

pub fn len(&self) -> usize

Return the number of entries currently waiting for replay.

Panics

This function does not panic.

pub fn is_empty(&self) -> bool

Return true if no entries are queued.

Panics

This function does not panic.

pub async fn replay_all(&self, sender: &Sender<PromptRequest>)

Re-inject all eligible entries back into the pipeline.

An entry is eligible if ReplayEntry::is_ready returns true (i.e. its exponential-backoff window has elapsed).

Between consecutive sends the scheduler applies exponential backoff (from the entry’s own attempts counter), sleeping the current task for the computed delay. Entries that are sent successfully are removed from the queue. Entries whose Sender is closed are left in the queue and a warn! is emitted.

Panics

This function does not panic.

pub async fn replay_by_session( &self, session_id: &SessionId, sender: &Sender<PromptRequest>, )

Re-inject all entries belonging to session_id back into the pipeline.

Behaviour is identical to replay_all but only entries whose request.session matches session_id are attempted.

Panics

This function does not panic.

pub fn age_out(&self, max_age: Duration)

Remove and discard all entries older than max_age.

Increments dlq_aged_out_total and the aged_out_total atomic for each evicted entry.

Panics

This function does not panic.

Trait Implementations

impl Clone for DlqReplayScheduler

fn clone(&self) -> DlqReplayScheduler

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for DlqReplayScheduler

fn default() -> Self

Returns the “default value” for a type.