Struct RollbackManager 

pub struct RollbackManager;

Manages rollback steps and recovery for failed workflows

Responsible for:

• Tracking rollback steps for each executed step
• Executing rollback steps in reverse order on failure
• Restoring workflow state after rollback

Implementations

impl RollbackManager

pub fn create_rollback_plan(workflow: &Workflow) -> RollbackPlan

Create a rollback plan for a workflow

pub fn execute_rollback( workflow: &Workflow, state: &mut WorkflowState, rollback_plan: &RollbackPlan, ) -> WorkflowResult<()>

Execute rollback steps in reverse order

Executes all rollback steps that were defined for the failed step, in reverse order of execution.

pub fn restore_state(state: &mut WorkflowState) -> WorkflowResult<()>

Restore workflow state after rollback

Clears the completed steps and step results to restore the workflow to a state where it can be resumed or restarted.

pub fn has_rollback_steps(rollback_plan: &RollbackPlan, step_id: &str) -> bool

Check if a step has rollback steps defined

pub fn get_rollback_steps( rollback_plan: &RollbackPlan, step_id: &str, ) -> Vec<String>

Get rollback steps for a specific step

pub fn add_rollback_step( rollback_plan: &mut RollbackPlan, step_id: String, rollback_step: String, )

Add a rollback step to the plan

pub fn record_step_execution(rollback_plan: &mut RollbackPlan, step_id: String)

Record step execution in the rollback plan