Struct Saga

pub struct Saga { /* private fields */ }

Workflow-local deterministic saga compensation helper.

Register each compensation only after its forward step succeeds. Passing the forward Result to Saga::finish runs compensations sequentially in reverse registration order after any failure, including cooperative cancellation. Each compensation is an ordinary durable activity, so replay, duplicate delivery, and worker restart use existing history semantics.

Implementations

impl Saga

pub fn add_compensation<T: Serialize>( &mut self, activity_type: impl Into<String>, args: T, ) -> Result<&mut Self>

pub fn add_compensation_with_options<T: Serialize>( &mut self, activity_type: impl Into<String>, options: ActivityOptions, args: T, ) -> Result<&mut Self>

pub async fn compensate(self, initiating_failure: Error) -> Error

Compensate initiating_failure and return the failure that must remain.

pub async fn finish<T>(self, outcome: Result<T>) -> Result<T>

Return a successful forward value or compensate and preserve its failure.