Struct MigrationState 

pub struct MigrationState { /* private fields */ }

State of an in-progress migration.

Implementations

impl MigrationState

pub fn new(daemon_origin: u64, source_node: u64, target_node: u64) -> Self

Create a new migration.

pub fn set_snapshot( &mut self, snapshot: StateSnapshot, ) -> Result<(), MigrationError>

Set the snapshot and advance to Transfer phase.

pub fn transfer_complete(&mut self) -> Result<(), MigrationError>

Mark transfer complete, advance to Restore.

pub fn restore_complete(&mut self) -> Result<(), MigrationError>

Mark restore complete, advance to Replay.

pub fn replay_complete(&mut self) -> Result<(), MigrationError>

Mark replay complete, advance to Cutover.

pub fn cutover_complete(&mut self) -> Result<(), MigrationError>

Mark cutover complete, advance to Complete.

pub fn is_complete(&self) -> bool

Check if migration is finished.

pub fn elapsed_ms(&self) -> u64

Elapsed time in milliseconds since the migration was constructed. Backed by a monotonic Instant, so a system clock that jumps backward (NTP step, VM resume) does not reset this to 0; long-running migrations stay observable in operator dashboards.

pub fn age_in_phase_ms(&self) -> u64

Milliseconds since the current phase was entered. Same monotonic source as Self::elapsed_ms; resets on every phase transition.

pub fn retry_count(&self) -> u32

Number of retries this migration has accumulated.

pub fn bump_retry(&mut self)

Increment the retry counter. Saturating at u32::MAX so a stuck retry loop never wraps to 0 and masks the retry pressure from operator dashboards.

pub fn snapshot_size_bytes(&self) -> Option<u64>

Payload byte count of the snapshot once set; None while the snapshot phase is still in progress (or when the orchestrator advanced past Snapshot via force_phase without calling set_snapshot).

pub fn daemon_origin(&self) -> u64

Get the daemon origin hash.

pub fn source_node(&self) -> u64

Get the source node ID.

pub fn target_node(&self) -> u64

Get the target node ID.

pub fn phase(&self) -> MigrationPhase

Get the current phase.

pub fn snapshot(&self) -> Option<&StateSnapshot>

Get the snapshot (if taken).

Trait Implementations

impl Debug for MigrationState

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.