Struct EventStore 

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

Available on crate feature cqrs only.

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: Event> EventStore<E, InMemoryBackend<E>>

pub fn new() -> Self

Create a new event store with in-memory backend

impl<E: Event, B: EventStoreBackend<E>> EventStore<E, B>

pub fn with_backend(backend: B) -> Self

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: Clone + Event, B: Clone + EventStoreBackend<E>> Clone for EventStore<E, B>

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: Event> Default for EventStore<E, InMemoryBackend<E>>

fn default() -> Self

Returns the “default value” for a type.