Struct MigrationManager 

pub struct MigrationManager { /* private fields */ }

Tracks all active migrations for a node.

Implementations

impl MigrationManager

pub fn new() -> Self

Create a new migration manager.

pub fn is_migrating(&self, slot: u16) -> bool

Check if a slot is currently migrating out.

pub fn is_importing(&self, slot: u16) -> bool

Check if a slot is currently being imported.

pub fn get_outgoing(&self, slot: u16) -> Option<&Migration>

Get migration info for a slot that’s migrating out.

pub fn get_incoming(&self, slot: u16) -> Option<&Migration>

Get migration info for a slot that’s being imported.

pub fn start_import( &mut self, slot: u16, source: NodeId, local_id: NodeId, ) -> Result<&Migration, MigrationError>

Start importing a slot from another node.

Returns error if slot is already involved in a migration.

pub fn start_migrate( &mut self, slot: u16, local_id: NodeId, target: NodeId, ) -> Result<&Migration, MigrationError>

Start migrating a slot to another node.

Returns error if slot is already involved in a migration.

pub fn key_migrated(&mut self, slot: u16, key: Vec<u8>)

Record that a key has been migrated.

pub fn is_key_migrated(&self, slot: u16, key: &[u8]) -> bool

Check if a specific key has been migrated.

pub fn complete_migration(&mut self, slot: u16) -> Option<Migration>

Complete a migration and clean up state.

pub fn abort_migration(&mut self, slot: u16) -> Option<Migration>

Abort a migration and clean up state.

pub fn outgoing_migrations(&self) -> impl Iterator<Item = &Migration>

Get all active outgoing migrations.

pub fn incoming_migrations(&self) -> impl Iterator<Item = &Migration>

Get all active incoming migrations.

pub fn active_count(&self) -> usize

Get total number of active migrations.

Trait Implementations

impl Debug for MigrationManager

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

Formats the value using the given formatter.

impl Default for MigrationManager

fn default() -> MigrationManager

Returns the “default value” for a type.