Struct fmodel_rust::saga_manager::SagaManager

pub struct SagaManager<A, AR, Publisher, Saga, Error>
where
    Publisher: ActionPublisher<A, Error>,
    Saga: ActionComputation<AR, A>,
{ /* private fields */ }

Saga Manager.

It is using a Saga to react to the action result and to publish the new actions. It is using an ActionPublisher to publish the new actions.

Generic parameters:

• A - Action / Command
• AR - Action Result / Event
• Publisher - Action Publisher
• Error - Error

Implementations

impl<A, AR, Publisher, Saga, Error> SagaManager<A, AR, Publisher, Saga, Error>

where Publisher: ActionPublisher<A, Error> + Sync, Saga: ActionComputation<AR, A> + Sync, A: Sync, AR: Sync, Error: Sync,

pub fn new(action_publisher: Publisher, saga: Saga) -> Self

Creates a new instance of SagaManager.

pub async fn handle(&self, action_result: &AR) -> Result<Vec<A>, Error>

Handles the action result by computing new actions based on action result, and publishing new actions to the external system. In most cases:

• the action result is an event that you react,
• the actions are commands that you publish downstream.

Trait Implementations

impl<A, AR, Publisher, Saga, Error> ActionComputation<AR, A> for SagaManager<A, AR, Publisher, Saga, Error>

where Publisher: ActionPublisher<A, Error>, Saga: ActionComputation<AR, A>,

fn compute_new_actions(&self, action_result: &AR) -> Vec<A>

Computes new actions based on the action result.

impl<A, AR, Publisher, Saga, Error> ActionPublisher<A, Error> for SagaManager<A, AR, Publisher, Saga, Error>

where Publisher: ActionPublisher<A, Error> + Sync, Saga: ActionComputation<AR, A> + Sync, A: Sync, AR: Sync, Error: Sync,

fn publish<'life0, 'life1, 'async_trait>( &'life0 self, action: &'life1 [A] ) -> Pin<Box<dyn Future<Output = Result<Vec<A>, Error>> + Send + 'async_trait>>

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

Publishes the action/command to some external system, returning either the actions that are successfully published or error.