Struct Saga 

pub struct Saga {
    pub saga_id: String,
    pub steps: Vec<SagaStep>,
    pub state: SagaState,
    pub current_step: usize,
    pub results: HashMap<String, String>,
}

A saga orchestrating multi-step ceremonies.

Fields

saga_id: String

steps: Vec<SagaStep>

state: SagaState

current_step: usize

results: HashMap<String, String>

Implementations

impl Saga

pub fn new(saga_id: &str, step_names: &[&str]) -> Self

pub fn execute<F>(&mut self, step_fn: F) -> Result<(), String>

where F: FnMut(&str) -> Result<String, String>,

Execute the saga forward. Returns Ok when all steps complete, Err when a step fails (triggers compensation).

pub fn compensate<F>(&mut self, compensate_fn: F) -> Result<(), String>

where F: FnMut(&str) -> Result<(), String>,

Compensate (roll back) completed steps in reverse order.

pub fn progress(&self) -> f64

pub fn completed_steps(&self) -> Vec<&str>

pub fn step_count(&self) -> usize