Struct Saga 

pub struct Saga<Input, Output, Ctx, Err> { /* private fields */ }

A compiled saga ready for execution.

Sagas execute a sequence of steps, where each step’s output becomes the next step’s input. If any step fails, previously completed steps are compensated in reverse order (LIFO).

Implementations

impl<Input, Output, Ctx, Err> Saga<Input, Output, Ctx, Err>

where Input: Clone + Send + 'static, Output: Send + 'static, Err: Debug,

pub fn execute(&self, ctx: &Ctx, input: Input) -> Result<Output, SagaError<Err>>

Execute the saga, returning the final output on success.

On failure, compensates all previously completed steps in reverse order.

Errors

Returns SagaError::StepFailed if a step fails and all compensations succeed. Returns SagaError::CompensationFailed if a step fails and some compensations also fail.

pub fn execute_with_audit( &self, ctx: &Ctx, input: Input, ) -> (Result<Output, SagaError<Err>>, SagaAuditLog)

Execute the saga and return both the result and an audit log.

The audit log tracks all step executions and compensations.