Struct MemoryProcessedLog 

pub struct MemoryProcessedLog { /* private fields */ }

In-memory ProcessedEventLog backed by dashmap::DashMap.

Intended for tests and single-process development. State is lost on process restart and is not shared across processes. Use a DB-backed impl in production.

Implementations

impl MemoryProcessedLog

pub fn new() -> Self

Creates an empty in-memory log.

Trait Implementations

impl Default for MemoryProcessedLog

fn default() -> Self

Returns the “default value” for a type.

impl ProcessedEventLog for MemoryProcessedLog

fn try_mark_processed<'life0, 'life1, 'async_trait>( &'life0 self, event_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<bool, Error>> + Send + 'async_trait>>

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

Attempts to mark event_id as processed.