Struct ReliabilityManager 

pub struct ReliabilityManager { /* private fields */ }

Reliability manager for message producers

Implementations

impl ReliabilityManager

pub fn new(config: ReliabilityConfig) -> Self

Create a new reliability manager

pub async fn start(&self) -> Result<()>

Start background tasks for reliability management

pub async fn prepare_message( &self, event: StreamEvent, ) -> Result<ReliableMessage>

Prepare message for reliable delivery

pub async fn record_delivery(&self, message_id: &str) -> Result<()>

Record successful delivery

pub async fn record_failure( &self, message_id: &str, error: String, ) -> Result<DeliveryStatus>

Record delivery failure

pub async fn get_retry_message(&self) -> Option<ReliableMessage>

Get next message from retry queue

pub async fn get_dlq_messages(&self, limit: usize) -> Vec<ReliableMessage>

Get DLQ messages

pub async fn clear_dlq(&self) -> Result<()>

Clear DLQ

pub async fn get_stats(&self) -> ReliabilityStats

Get reliability statistics

pub async fn shutdown(&mut self) -> Result<()>

Shutdown reliability manager

pub async fn replay_message(&self, message_id: &str) -> Result<ReliableMessage>

Replay a single message from DLQ by message ID

pub async fn replay_messages_with_filter<F>( &self, filter: F, limit: usize, ) -> Result<Vec<ReliableMessage>>

where F: Fn(&ReliableMessage) -> bool,

Replay multiple messages from DLQ with optional filter

pub async fn remove_from_dlq(&self, message_id: &str) -> Result<()>

Remove successfully replayed message from DLQ

pub async fn update_replay_status( &self, message_id: &str, status: ReplayStatus, ) -> Result<()>

Update replay status for a message in DLQ

pub async fn get_dlq_stats(&self) -> DlqStats

Get DLQ statistics for monitoring

pub async fn bulk_replay_messages( &self, message_ids: Vec<String>, ) -> Result<BulkReplayResult>

Bulk replay messages with batching