Struct InMemoryMobEventStore 

pub struct InMemoryMobEventStore { /* private fields */ }

In-memory event store for tests and ephemeral mobs.

Implementations

impl InMemoryMobEventStore

pub fn new() -> Self

Trait Implementations

impl Debug for InMemoryMobEventStore

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

Formats the value using the given formatter.

impl Default for InMemoryMobEventStore

fn default() -> InMemoryMobEventStore

Returns the “default value” for a type.

impl MobEventStore for InMemoryMobEventStore

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

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

Append a new event to the store.

fn append_batch<'life0, 'async_trait>( &'life0 self, batch: Vec<NewMobEvent>, ) -> Pin<Box<dyn Future<Output = Result<Vec<MobEvent>, MobStoreError>> + Send + 'async_trait>>

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

Append multiple events atomically.

fn poll<'life0, 'async_trait>( &'life0 self, after_cursor: u64, limit: usize, ) -> Pin<Box<dyn Future<Output = Result<Vec<MobEvent>, MobStoreError>> + Send + 'async_trait>>

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

Poll for events after a given cursor, up to a limit.

fn replay_all<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<Vec<MobEvent>, MobStoreError>> + Send + 'async_trait>>

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

Replay all events from the beginning.

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

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

Delete all persisted events.

fn prune<'life0, 'async_trait>( &'life0 self, older_than: DateTime<Utc>, ) -> Pin<Box<dyn Future<Output = Result<u64, MobStoreError>> + Send + 'async_trait>>

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

Prune events older than a timestamp. Returns count of deleted events.