Struct MigrationStateTable 

pub struct MigrationStateTable { /* private fields */ }

In-memory mirror of _cluster.migration_state.

Mutations go through MigrationStateTable methods which update both the in-memory HashMap and the backing redb table atomically. The Arc<Mutex<_>> wrapper allows the table to be shared across the CacheApplier and MigrationExecutor without a lifetime tie-in.

ClusterCatalog is held as Arc to survive actor hand-offs.

Implementations

impl MigrationStateTable

pub const TABLE: TableDefinition<'static, &'static str, &'static [u8]>

pub fn new(db: Arc<Database>) -> Self

Create a new, empty in-memory table backed by db.

pub fn load_all(&mut self) -> Result<()>

Load all persisted checkpoints from redb into the in-memory map.

Called once at startup before recovery runs.

pub fn upsert(&mut self, row: PersistedMigrationCheckpoint) -> Result<()>

Upsert a checkpoint row (in-memory + redb).

Idempotent: if the exact (migration_id, phase, attempt) tuple is already stored, this is a no-op.

pub fn remove(&mut self, migration_id: &MigrationId) -> Result<()>

Remove a checkpoint row (in-memory + redb). No-op if not present.

pub fn all_checkpoints(&self) -> Vec<PersistedMigrationCheckpoint>

Get a snapshot of all in-flight checkpoints (in-memory view).

pub fn get( &self, migration_id: &MigrationId, ) -> Option<&PersistedMigrationCheckpoint>

Lookup the latest checkpoint for a migration ID.