Struct EventStore 

pub struct EventStore<E, B = InMemoryBackend<E>>
where
    E: Event,
    B: EventStoreBackend<E>,
{ /* private fields */ }

Event Store - append-only log of domain events

The EventStore uses a pluggable backend architecture:

• Default: InMemoryBackend (for testing/MVP)
• Production: AllSourceBackend (requires cqrs-allsource feature)

Implementations

impl<E> EventStore<E>

where E: Event,

pub fn new() -> EventStore<E>

Create a new event store with in-memory backend

impl<E, B> EventStore<E, B>

where E: Event, B: EventStoreBackend<E>,

pub fn with_backend(backend: B) -> EventStore<E, B>

Create a new event store with a custom backend

pub fn backend(&self) -> &B

Get a reference to the backend

pub async fn append( &self, aggregate_id: &str, events: Vec<E>, ) -> Result<(), String>

Append events to an aggregate’s event stream

pub async fn get_events(&self, aggregate_id: &str) -> Result<Vec<E>, String>

Get all events for an aggregate

pub async fn get_all_events(&self) -> Result<Vec<E>, String>

Get all events from all aggregates (for projection rebuild)

pub async fn get_events_after( &self, aggregate_id: &str, version: u64, ) -> Result<Vec<E>, String>

Get events after a specific version (for snapshot optimization)

pub async fn subscribe(&self, tx: Sender<E>)

Subscribe to event stream

pub async fn save_snapshot<A>( &self, aggregate_id: &str, snapshot: Snapshot<A>, ) -> Result<(), String>

where A: Aggregate<Event = E> + Serialize,

Save a snapshot

pub async fn get_latest_snapshot<A>( &self, aggregate_id: &str, ) -> Result<Snapshot<A>, String>

where A: Aggregate<Event = E> + DeserializeOwned,

Get latest snapshot

pub async fn flush(&self) -> Result<(), String>

Flush pending writes to storage (useful with WAL or batching backends)

pub async fn stats(&self) -> BackendStats

Get backend statistics

Trait Implementations

impl<E, B> Clone for EventStore<E, B>

where E: Clone + Event, B: Clone + EventStoreBackend<E>,

fn clone(&self) -> EventStore<E, B>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<E> Default for EventStore<E>

where E: Event,

fn default() -> EventStore<E>

Returns the “default value” for a type.