Struct DeadLetterQueue 

pub struct DeadLetterQueue { /* private fields */ }

Dead Letter Queue manager

Implementations

impl DeadLetterQueue

pub fn new(config: DlqConfig) -> Self

Create a new DLQ

pub async fn handle_failed_event( &self, event: StreamEvent, failure_reason: FailureReason, error_message: String, ) -> Result<()>

Handle a failed event

pub async fn process_retries<F, Fut>( &self, retry_fn: F, ) -> Result<Vec<StreamEvent>>

where F: Fn(StreamEvent) -> Fut + Send + Sync, Fut: Future<Output = Result<()>> + Send,

Process retry queue

pub async fn replay_dlq<F, Fut>( &self, replay_fn: F, max_events: Option<usize>, ) -> Result<Vec<StreamEvent>>

where F: Fn(StreamEvent) -> Fut + Send + Sync, Fut: Future<Output = Result<()>> + Send,

Replay events from DLQ

pub async fn get_by_reason(&self, reason: &FailureReason) -> Vec<FailedEvent>

Get events from DLQ by failure reason

pub async fn remove_from_dlq( &self, predicate: impl Fn(&FailedEvent) -> bool, ) -> usize

Remove specific event from DLQ

pub async fn clear_dlq(&self)

Clear DLQ

pub async fn stats(&self) -> DlqStats

Get DLQ statistics

pub async fn retry_queue_size(&self) -> usize

Get retry queue size

pub async fn dlq_size(&self) -> usize

Get DLQ size

pub async fn get_all_dlq_events(&self) -> Vec<FailedEvent>

Get all DLQ events