Struct DeadLetterQueue 

pub struct DeadLetterQueue { /* private fields */ }

In-memory dead letter queue for failed handler events.

Thread-safe — uses internal Mutex. For production, back with a database table.

Implementations

impl DeadLetterQueue

pub fn new(config: DlqConfig) -> Self

Create a new DLQ with the given configuration.

pub fn push( &self, event: DecodedEvent, handler_name: impl Into<String>, error_message: impl Into<String>, )

Push a failed event into the DLQ.

The entry is scheduled for retry based on the configured backoff.

pub fn pop_ready(&self, now: i64) -> Vec<DlqEntry>

Pop all entries that are due for retry (next_retry_at <= now).

Returns entries with status set to Retrying.

pub fn mark_success(&self, id: &str)

Mark an entry as successfully retried (removes it from the DLQ).

pub fn mark_failed(&self, id: &str, error_message: impl Into<String>)

Mark an entry as failed again (reschedule or permanently fail).

pub fn get_by_status(&self, status: DlqStatus) -> Vec<DlqEntry>

Get all entries with a specific status.

pub fn get(&self, id: &str) -> Option<DlqEntry>

Get a single entry by ID.

pub fn len(&self) -> usize

Total number of entries in the DLQ.

pub fn is_empty(&self) -> bool

Returns true if the DLQ is empty.

pub fn purge_before(&self, timestamp: i64) -> usize

Purge (remove) all entries with last_failed_at before the given timestamp.

pub fn retry_all_failed(&self) -> usize

Reset all Failed entries to Pending for another round of retries.

pub fn stats(&self) -> DlqStats

Get current DLQ statistics.

Trait Implementations

impl Default for DeadLetterQueue

fn default() -> Self

Returns the “default value” for a type.