Struct InMemoryEventStore 

pub struct InMemoryEventStore { /* private fields */ }

In-memory event store (for testing/development)

Implementations

impl InMemoryEventStore

pub fn new() -> 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 Default for InMemoryEventStore

fn default() -> InMemoryEventStore

Returns the “default value” for a type.

impl EventStore for InMemoryEventStore

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

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

Append an event to the log

fn get_by_execution<'life0, 'life1, 'async_trait>( &'life0 self, execution_id: &'life1 ExecutionId, ) -> Pin<Box<dyn Future<Output = Result<Vec<EventLogEntry>>> + Send + 'async_trait>>

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

Get events for an execution

fn get_after<'life0, 'async_trait>( &'life0 self, after_sequence: u64, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<EventLogEntry>>> + Send + 'async_trait>>

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

Get events after a sequence number

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

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

Get the latest sequence number