Struct InMemoryEventStore 

pub struct InMemoryEventStore { /* private fields */ }

In-memory event store implementation.

Implementations

impl InMemoryEventStore

pub fn new(max_events: usize, max_age: Duration) -> Self

Create a new in-memory event store.

Trait Implementations

impl Debug for InMemoryEventStore

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

Formats the value using the given formatter.

impl EventStore for InMemoryEventStore

fn store_event<'life0, 'async_trait>( &'life0 self, event: StoredEvent, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

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

Store an event with its metadata.

fn get_events_since<'life0, 'life1, 'async_trait>( &'life0 self, event_id: &'life1 str, limit: Option<usize>, ) -> Pin<Box<dyn Future<Output = Result<Vec<StoredEvent>>> + Send + 'async_trait>>

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

Retrieve events since a given event ID.

fn get_latest_event_id<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Option<String>>> + Send + 'async_trait>>

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

Get the latest event ID.

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

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

Clear events older than the specified timestamp.

fn create_resumption_token<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<ResumptionToken>> + Send + 'async_trait>>

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

Get resumption token for current state.

fn validate_resumption_token<'life0, 'life1, 'async_trait>( &'life0 self, token: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<ResumptionState>>> + Send + 'async_trait>>

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

Validate and retrieve state from resumption token.