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>, Decider: EventComputation<C, S, E>,

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.