Struct MigrationRunner 

pub struct MigrationRunner {
    pub history: Mutex<Vec<MigrationRecord>>,
    pub current_version: AtomicU32,
    pub stats: MigrationStats,
}

Executes migration plans and tracks history.

All mutation is performed through shared references so that the runner can be wrapped in an Arc and used from multiple threads.

Fields

history: Mutex<Vec<MigrationRecord>>

Full history of every step that has been executed.

current_version: AtomicU32

Current schema version, updated atomically after each successful step.

stats: MigrationStats

Cumulative statistics.

Implementations

impl MigrationRunner

pub fn new(initial_version: SchemaVersion) -> Self

Create a runner starting at initial_version.

pub fn execute_step( &self, step: &MigrationStep, blocks_count: u64, ) -> Result<MigrationRecord, MigrationError>

Execute a single migration step (no actual I/O — simulates the step).

Records the outcome in the history log and updates statistics.

pub fn execute_plan( &self, plan: &MigrationPlan, blocks_per_step: u64, ) -> Result<Vec<MigrationRecord>, MigrationError>

Execute every step in a MigrationPlan sequentially.

Returns the list of completed MigrationRecords. If any step fails the error is returned immediately and subsequent steps are not executed.

pub fn current_version(&self) -> SchemaVersion

Return the current schema version.

pub fn history(&self) -> Vec<MigrationRecord>

Return a clone of the full history.

pub fn can_rollback(&self) -> bool

Returns true when the most recent step was reversible and can be rolled back.