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_events_after( &self, aggregate_id: &str, version: u64, ) -> Result<Vec<E>, String>

Get events after a specific version 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 subscribe(&self, tx: Sender<E>)

Subscribe to event stream

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.