Struct EventSourcingRepository 

pub struct EventSourcingRepository<T> { /* private fields */ }

Event sourcing repository for managing aggregates

Implementations

impl<T> EventSourcingRepository<T>

where T: AggregateRoot + Send + Sync,

pub fn new(event_store: Arc<dyn EventStore + Send + Sync>) -> Self

pub fn with_snapshot_frequency(self, frequency: u64) -> Self

pub async fn load(&self, aggregate_id: &AggregateId) -> Result<Option<T>>

Load aggregate from event store

pub async fn save(&self, aggregate: &mut T) -> Result<()>

Save aggregate to event store

pub async fn exists(&self, aggregate_id: &AggregateId) -> Result<bool>

Check if aggregate exists