Struct DeadLetterQueue 

pub struct DeadLetterQueue { /* private fields */ }

Durable storage for tasks that exhausted their retries.

Entries are persisted under dlq:{task_id} so they survive restarts and can be inspected or replayed by an operator.

Implementations

impl DeadLetterQueue

pub fn new(storage: Arc<dyn Storage>) -> Self

Wrap a storage backend as a dead-letter queue.

pub async fn push( &self, task_id: &str, attempts: u32, error: impl Into<String>, ) -> Result<()>

Add a failed task to the queue.

pub async fn get(&self, task_id: &str) -> Result<Option<DeadLetter>>

Fetch the dead-letter entry for a task, if present.

pub async fn list(&self) -> Result<Vec<DeadLetter>>

List all dead-lettered entries.

pub async fn remove(&self, task_id: &str) -> Result<()>

Remove a task from the queue (e.g. after a successful manual replay).