Struct StateStoredOrchestratingAggregate

pub struct StateStoredOrchestratingAggregate<'a, C, S, E, Repository, Version, Error>
where
    Repository: StateRepository<C, S, Version, Error>,
{ /* private fields */ }

Orchestrating State Stored Aggregate.

It is using a Decider and Saga to compute new state based on the current state and the command. If the decider is combined out of many deciders via combine function, a saga could be used to react on new events and send new commands to the decider recursively, in single transaction. It is using a StateRepository to fetch the current state and to save the new state.

Generic parameters:

• C - Command
• S - State
• E - Event
• Repository - State repository
• Version - Version
• Error - Error

Implementations

impl<'a, C, S, E, Repository, Version, Error> StateStoredOrchestratingAggregate<'a, C, S, E, Repository, Version, Error>

where Repository: StateRepository<C, S, Version, Error> + Sync, C: Sync, S: Sync + Clone, E: Sync, Version: Sync, Error: Sync,

pub fn new( repository: Repository, decider: Decider<'a, C, S, E, Error>, saga: Saga<'a, E, C>, ) -> Self

Creates a new instance of StateStoredAggregate.

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

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

Trait Implementations

impl<C, S, E, Repository, Version, Error> StateComputation<C, S, E, Error> for StateStoredOrchestratingAggregate<'_, C, S, E, Repository, Version, Error>

where Repository: StateRepository<C, S, Version, Error>, S: Clone,

fn compute_new_state( &self, current_state: Option<S>, command: &C, ) -> Result<S, Error>

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

impl<C, S, E, Repository, Version, Error> StateRepository<C, S, Version, Error> for StateStoredOrchestratingAggregate<'_, C, S, E, Repository, Version, Error>

where Repository: StateRepository<C, S, Version, Error> + Sync, C: Sync, S: Sync, E: Sync, Version: Sync, Error: Sync,

async fn fetch_state(&self, command: &C) -> Result<Option<(S, Version)>, Error>

Fetches current state, based on the command.

async fn save( &self, state: &S, version: &Option<Version>, ) -> Result<(S, Version), Error>

Saves state.