event_hex 0.0.3

A pragmatic Rust toolkit for Domain-Driven Design with first-class support for event sourcing and CQRS.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use crate::domain::{AggregateContainer, AggregateRoot, EntityId};
use crate::domain_event::{DomainEvent, Snapshot, StoredEvent};
use crate::errors::EventStoreError;
use crate::persistence::transaction::EventTransactionContext;
use async_trait::async_trait;

/// Shared Event Repository
#[async_trait]
pub trait EventStoreRepository<A>: Send + Sync
where
    A: AggregateRoot + Send + Sync + 'static,
{
    // Method for saving aggregate changes.
    async fn save_aggregate(&self, ctx: &mut dyn EventTransactionContext, aggregate: AggregateContainer<A>) -> Result<(), EventStoreError>
    where
        A::Event: DomainEvent;
    // Method for loading an aggregate by its ID
    async fn load_aggregate(&self, ctx: &mut dyn EventTransactionContext, id: &EntityId) -> Result<Option<AggregateContainer<A>>, EventStoreError>;
    async fn get_events_since_version(&self, ctx: &mut dyn EventTransactionContext, id: &EntityId, version: u32) -> Result<Vec<StoredEvent>, EventStoreError>;
    async fn get_latest_snapshot(&self, ctx: &mut dyn EventTransactionContext, id: &EntityId) -> Result<Option<Snapshot<A>>, EventStoreError>;
}