Struct RebaseStateMachine 

pub struct RebaseStateMachine { /* private fields */ }

State machine for fault-tolerant rebase operations.

This state machine manages rebase operations with:

• Checkpoint-based persistence
• Automatic recovery from interruptions
• Maximum recovery attempt limits
• Conflict tracking

Implementations

impl RebaseStateMachine

pub fn new(upstream_branch: String) -> Self

Create a new state machine for a rebase operation.

Arguments

• upstream_branch - The branch to rebase onto

pub fn load_or_create(upstream_branch: String) -> Result<Self>

Load an existing state machine from checkpoint or create a new one.

If a checkpoint exists, this will resume from that state. Otherwise, creates a new state machine.

This method handles corrupted checkpoints by:

• Attempting to load backup checkpoint
• Creating a fresh state if checkpoint is completely corrupted

Arguments

• upstream_branch - The branch to rebase onto (used if no checkpoint exists)

Returns

Returns Ok(state_machine) if successful, or an error if loading fails.

pub fn with_max_recovery_attempts(self, max: u32) -> Self

Set the maximum number of recovery attempts.

pub fn transition_to(&mut self, phase: RebasePhase) -> Result<()>

Transition to a new phase and save checkpoint.

Arguments

• phase - The new phase to transition to

Returns

Returns Ok(()) if the transition succeeded, or an error if saving failed.

pub fn record_conflict(&mut self, file: String)

Record a conflict in a file.

Arguments

• file - The file path that has conflicts

pub fn record_resolution(&mut self, file: String)

Record that a conflict has been resolved.

Arguments

• file - The file path that was resolved

pub fn record_error(&mut self, error: String)

Record an error that occurred.

Arguments

• error - The error message to record

pub fn all_conflicts_resolved(&self) -> bool

Check if all conflicts have been resolved.

Returns true if all conflicted files have been marked as resolved.

pub fn checkpoint(&self) -> &RebaseCheckpoint

Get the current checkpoint.

pub fn phase(&self) -> &RebasePhase

Get the current phase.

pub fn upstream_branch(&self) -> &str

Get the upstream branch.

pub fn unresolved_conflict_count(&self) -> usize

Get the number of unresolved conflicts.

pub fn clear_checkpoint(self) -> Result<()>

Clear the checkpoint (typically on successful completion).