Struct DeadLetterQueue 

pub struct DeadLetterQueue { /* private fields */ }

Dead Letter Queue operations for PostgreSQL

Implementations

impl DeadLetterQueue

pub fn new(pool: PgPool) -> Self

pub async fn insert( &self, event_id: Uuid, handler_id: &str, intent_id: Uuid, error_message: &str, error_details: Option<Value>, retry_count: i32, first_failed_at: DateTime<Utc>, last_failed_at: DateTime<Utc>, event_payload: Value, ) -> Result<Uuid>

Insert a handler failure into the DLQ

pub async fn list(&self, limit: i64) -> Result<Vec<CoreDeadLetter>>

List open or retrying DLQ entries

pub async fn list_by_handler( &self, handler_id: &str, limit: i64, ) -> Result<Vec<CoreDeadLetter>>

List DLQ entries for a specific handler

pub async fn get(&self, dlq_id: Uuid) -> Result<CoreDeadLetter>

Get a single DLQ entry by ID

pub async fn start_retry(&self, dlq_id: Uuid) -> Result<CoreDeadLetter>

Mark a DLQ entry as retrying and return it (with lock)

pub async fn mark_replayed( &self, dlq_id: Uuid, resolution_note: Option<&str>, ) -> Result<()>

Mark a DLQ entry as successfully replayed

pub async fn mark_retry_failed( &self, dlq_id: Uuid, error_message: &str, error_details: Option<Value>, ) -> Result<()>

Mark a DLQ entry as failed (retry failed, back to open)

pub async fn mark_resolved( &self, dlq_id: Uuid, resolution_note: &str, ) -> Result<()>

Mark a DLQ entry as resolved (won’t retry, manual fix)

pub async fn stats(&self) -> Result<DlqStats>

Get statistics about the DLQ

Trait Implementations

impl Clone for DeadLetterQueue

fn clone(&self) -> DeadLetterQueue

Returns a duplicate of the value.

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

Performs copy-assignment from source.