Struct PeerMigrationManager 

pub struct PeerMigrationManager { /* private fields */ }

Manages peer state migrations for seamless node handoff.

Implementations

impl PeerMigrationManager

pub fn new(config: PeerMigrationConfig) -> Self

Create a new migration manager with the given configuration.

pub fn start_migration( &mut self, source: &str, target: &str, total_items: u64, ) -> Result<u64, String>

Start a new migration from source to target.

Returns the migration ID on success, or an error if the concurrent migration limit has been reached or the parameters are invalid.

pub fn add_items( &mut self, migration_id: u64, new_items: Vec<MigrationItem>, ) -> Result<(), String>

Add items to an active migration.

The migration must be in the Transferring state. Each item’s bytes are counted toward the transfer total.

pub fn advance_state( &mut self, migration_id: u64, ) -> Result<PeerMigrationState, String>

Advance the migration to its next state.

State transitions follow: Preparing -> Transferring -> Verifying -> Completed

The Verifying -> Completed transition only succeeds if all items have been transferred (when verify_after_transfer is enabled).

pub fn complete_migration( &mut self, migration_id: u64, checksum: u64, ) -> Result<(), String>

Mark a migration as completed with a final checksum.

The migration must be in the Verifying state. If verify_after_transfer is enabled, the provided checksum is compared against the computed one.

pub fn fail_migration( &mut self, migration_id: u64, reason: &str, ) -> Result<(), String>

Mark a migration as failed with the given reason.

pub fn get_migration(&self, migration_id: u64) -> Option<&PeerMigrationRecord>

Get a reference to a migration record by ID.

Searches both active and completed migrations.

pub fn progress(&self, migration_id: u64) -> Option<f64>

Get the progress of a migration as a value between 0.0 and 1.0.

Returns None if the migration does not exist.

pub fn active_count(&self) -> usize

Return the number of currently active (non-completed, non-failed) migrations.

pub fn cleanup_completed(&mut self, before: u64) -> usize

Remove completed/failed migrations with completed_at before the given timestamp.

Returns the number of records removed.

pub fn stats(&self) -> &PeerMigrationStats

Get a reference to the aggregate migration statistics.

pub fn migrations_for_peer(&self, peer: &str) -> Vec<&PeerMigrationRecord>

Find all migrations (active and completed) involving a given peer, either as source or target.

pub fn config(&self) -> &PeerMigrationConfig

Get the configuration of this manager.

pub fn get_items(&self, migration_id: u64) -> Option<&[MigrationItem]>

Get the stored items for a migration (if still active).