Struct fmodel_rust::aggregate::EventSourcedAggregate

pub struct EventSourcedAggregate<C, S, E, Repository, Decider, Version, Error>
where
    Repository: EventRepository<C, E, Version, Error>,
    Decider: EventComputation<C, S, E>,
{ /* private fields */ }

Event Sourced Aggregate.

It is using a Decider / EventComputation to compute new events based on the current events and the command. It is using a EventRepository to fetch the current events and to save the new events.

Generic parameters:

• C - Command
• S - State
• E - Event
• Repository - Event repository
• Decider - Event computation
• Version - Version/Offset/Sequence number
• Error - Error

Implementations

impl<C, S, E, Repository, Decider, Version, Error> EventSourcedAggregate<C, S, E, Repository, Decider, Version, Error>

where Repository: EventRepository<C, E, Version, Error> + Sync, Decider: EventComputation<C, S, E> + Sync, C: Sync, S: Sync, E: Sync, Version: Sync, Error: Sync,

pub fn new(repository: Repository, decider: Decider) -> Self

Creates a new instance of EventSourcedAggregate.

pub async fn handle(&self, command: &C) -> Result<Vec<(E, Version)>, Error>

Handles the command by fetching the events from the repository, computing new events based on the current events and the command, and saving the new events to the repository.

Trait Implementations

impl<C, S, E, Repository, Decider, Version, Error> EventComputation<C, S, E> for EventSourcedAggregate<C, S, E, Repository, Decider, Version, Error>

where Repository: EventRepository<C, E, Version, Error>, Decider: EventComputation<C, S, E>,

fn compute_new_events(&self, current_events: &[E], command: &C) -> Vec<E>

Computes new events based on the current events and the command.

impl<C, S, E, Repository, Decider, Version, Error> EventRepository<C, E, Version, Error> for EventSourcedAggregate<C, S, E, Repository, Decider, Version, Error>

where Repository: EventRepository<C, E, Version, Error> + Sync, Decider: EventComputation<C, S, E> + Sync, C: Sync, S: Sync, E: Sync, Version: Sync, Error: Sync,

fn fetch_events<'life0, 'life1, 'async_trait>( &'life0 self, command: &'life1 C ) -> Pin<Box<dyn Future<Output = Result<Vec<(E, Version)>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Fetches current events, based on the command.

fn save<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, events: &'life1 [E], latest_version: &'life2 Option<Version> ) -> Pin<Box<dyn Future<Output = Result<Vec<(E, Version)>, Error>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait, 'life2: 'async_trait,

Saves events.