Struct SimpleEventStore 

pub struct SimpleEventStore { /* private fields */ }

Append-only, in-memory simple event store.

Implementations

impl SimpleEventStore

pub fn new() -> Self

Create an empty event store.

pub fn append( &mut self, aggregate_id: impl Into<String>, event_type: impl Into<String>, payload: impl Into<String>, ) -> SimpleEvent

Append a new event for aggregate_id.

pub fn load_aggregate(&self, aggregate_id: &str) -> Vec<SimpleEvent>

Load all events for the given aggregate, ordered by version.

pub fn load_from_version( &self, aggregate_id: &str, from_version: u64, ) -> Vec<SimpleEvent>

Load events for aggregate_id starting at from_version (inclusive).

pub fn load_all_events(&self) -> Vec<SimpleEvent>

Load every event across all aggregates.

pub fn len(&self) -> usize

Total number of events stored.

pub fn is_empty(&self) -> bool

True when the store is empty.

pub fn current_version(&self, aggregate_id: &str) -> u64

Current version for aggregate_id.

Trait Implementations

impl Default for SimpleEventStore

fn default() -> Self

Returns the “default value” for a type.