Struct SqliteAuditJournal 

pub struct SqliteAuditJournal { /* private fields */ }

Implementations

impl SqliteAuditJournal

pub const fn new(pool: SqlitePool) -> Self

pub async fn enqueue_in( &self, transaction: &mut Transaction<'_, Sqlite>, entry: AuditJournalEntry, ) -> Result<(), AuditLedgerError>

Trait Implementations

impl AuditJournalStore for SqliteAuditJournal

fn enqueue<'life0, 'async_trait>( &'life0 self, entry: AuditJournalEntry, ) -> Pin<Box<dyn Future<Output = Result<(), AuditLedgerError>> + Send + 'async_trait>>

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

fn claim_pending<'life0, 'life1, 'async_trait>( &'life0 self, worker_id: &'life1 str, limit: usize, claim_expires_at: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<Vec<AuditJournalEntry>, AuditLedgerError>> + Send + 'async_trait>>

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

fn mark_delivered<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, event_ids: &'life1 [Uuid], worker_id: &'life2 str, ) -> Pin<Box<dyn Future<Output = Result<(), AuditLedgerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

fn mark_retry<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, event_ids: &'life1 [Uuid], worker_id: &'life2 str, failure_code: &'life3 str, retry_at: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<(), AuditLedgerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

fn quarantine<'life0, 'life1, 'life2, 'life3, 'async_trait>( &'life0 self, event_ids: &'life1 [Uuid], worker_id: &'life2 str, failure_code: &'life3 str, ) -> Pin<Box<dyn Future<Output = Result<(), AuditLedgerError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait, 'life3: 'async_trait,

fn recover_expired_claims<'life0, 'async_trait>( &'life0 self, now: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<usize, AuditLedgerError>> + Send + 'async_trait>>

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

impl Clone for SqliteAuditJournal

fn clone(&self) -> SqliteAuditJournal

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SqliteAuditJournal

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.