pub struct MemoryAuditJournal { /* private fields */ }Implementations§
Source§impl MemoryAuditJournal
impl MemoryAuditJournal
pub async fn entries(&self) -> Vec<AuditJournalEntry>
Trait Implementations§
Source§impl AuditJournalStore for MemoryAuditJournal
impl AuditJournalStore for MemoryAuditJournal
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,
Source§impl Debug for MemoryAuditJournal
impl Debug for MemoryAuditJournal
Source§impl Default for MemoryAuditJournal
impl Default for MemoryAuditJournal
Source§fn default() -> MemoryAuditJournal
fn default() -> MemoryAuditJournal
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl !Freeze for MemoryAuditJournal
impl !RefUnwindSafe for MemoryAuditJournal
impl Send for MemoryAuditJournal
impl Sync for MemoryAuditJournal
impl Unpin for MemoryAuditJournal
impl UnsafeUnpin for MemoryAuditJournal
impl UnwindSafe for MemoryAuditJournal
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more