Struct ConnectionMigrationManager 

pub struct ConnectionMigrationManager { /* private fields */ }

Manages QUIC connection migration

Implementations

impl ConnectionMigrationManager

pub fn new(config: MigrationConfig) -> Self

Create a new connection migration manager

pub fn mobile() -> Self

Create with mobile-optimized configuration

pub fn conservative() -> Self

Create with conservative configuration

pub fn initiate_migration( &self, peer_id: PeerId, old_address: Multiaddr, new_address: Multiaddr, ) -> Result<(), MigrationError>

Initiate migration for a peer connection

Arguments

• peer_id - The peer to migrate
• old_address - Current network address
• new_address - New network address to migrate to

Returns

Ok if migration was initiated, Err if migration cannot start

pub fn update_migration_state( &self, peer_id: &PeerId, new_state: MigrationState, ) -> Result<(), MigrationError>

Update the state of an ongoing migration

pub fn complete_migration(&self, peer_id: &PeerId) -> Result<(), MigrationError>

Mark a migration as completed successfully

pub fn fail_migration( &self, peer_id: &PeerId, error: String, ) -> Result<(), MigrationError>

Mark a migration as failed

pub fn retry_migration(&self, peer_id: &PeerId) -> Result<(), MigrationError>

Retry a failed migration

pub fn is_migrating(&self, peer_id: &PeerId) -> bool

Check if a migration is in progress for a peer

pub fn get_migration_state(&self, peer_id: &PeerId) -> Option<MigrationState>

Get the current migration state for a peer

pub fn get_active_migrations(&self) -> Vec<MigrationAttempt>

Get all active migration attempts

pub fn stats(&self) -> MigrationStats

Get migration statistics

pub fn can_migrate(&self, peer_id: &PeerId) -> bool

Check if a peer can be migrated (respects cooldown)

pub fn config(&self) -> &MigrationConfig

Get the configuration

pub fn cleanup_timeouts(&self)

Clean up timed-out migrations