Struct SqliteDeadLetterQueue 

pub struct SqliteDeadLetterQueue { /* private fields */ }

SQLite-backed Dead Letter Queue

Implementations

impl SqliteDeadLetterQueue

pub fn new(conn: Connection) -> StorageResult<Self>

Create a new DLQ using an existing database connection

DLQ shares the same database file as mailbox but uses separate tables.

pub async fn new_standalone<P: AsRef<Path>>( database_path: P, ) -> StorageResult<Self>

Create a new DLQ with a separate database file

Trait Implementations

impl DeadLetterQueue for SqliteDeadLetterQueue

fn enqueue<'life0, 'async_trait>( &'life0 self, record: DlqRecord, ) -> Pin<Box<dyn Future<Output = StorageResult<Uuid>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Add a poison message to DLQ

fn query<'life0, 'async_trait>( &'life0 self, query: DlqQuery, ) -> Pin<Box<dyn Future<Output = StorageResult<Vec<DlqRecord>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Query DLQ records with filtering

fn get<'life0, 'async_trait>( &'life0 self, id: Uuid, ) -> Pin<Box<dyn Future<Output = StorageResult<Option<DlqRecord>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get a single DLQ record by ID

fn delete<'life0, 'async_trait>( &'life0 self, id: Uuid, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Delete a DLQ record (after manual resolution)

fn record_redrive_attempt<'life0, 'async_trait>( &'life0 self, id: Uuid, ) -> Pin<Box<dyn Future<Output = StorageResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Increment redrive attempt counter

fn stats<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = StorageResult<DlqStats>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Get DLQ statistics