Struct EventSourcedAggregate

pub struct EventSourcedAggregate<C, S, E, Repository, Decider, Version, Error>
where
    Repository: EventRepository<C, E, Version, Error>,
    Decider: EventComputation<C, S, E, Error>,
{ /* 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, Error> + 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, Error> for EventSourcedAggregate<C, S, E, Repository, Decider, Version, Error>

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

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

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, Error> + Sync, C: Sync, S: Sync, E: Sync, Version: Sync, Error: Sync,

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

Fetches current events, based on the command.

async fn save(&self, events: &[E]) -> Result<Vec<(E, Version)>, Error>

Saves events.

async fn version_provider(&self, event: &E) -> Result<Option<Version>, Error>

Version provider. It is used to provide the version/sequence of the event. Optimistic locking is useing this version to check if the event is already saved.