Method propose_checkpoint

nodedb-cluster/src/migration_executor/executor.rs:189–218

(
        &self,
        migration_id: MigrationId,
        attempt: u32,
        payload: MigrationCheckpointPayload,
    )

    }

    pub(super) async fn propose_checkpoint(
        &self,
        migration_id: MigrationId,
        attempt: u32,
        payload: MigrationCheckpointPayload,
    ) -> Result<()> {
        let Some(proposer) = &self.metadata_proposer else {
            return Ok(());
        };

        let ts_ms = SystemTime::now()
            .duration_since(UNIX_EPOCH)
            .unwrap_or_default()
            .as_millis() as u64;

        let crc32c = payload.crc32c()?;
        let phase = payload.phase_tag();

        let entry = Entry::MigrationCheckpoint {
            migration_id: migration_id.hyphenated().to_string(),
            phase,
            attempt,
            payload,
            crc32c,
            ts_ms,
        };

        proposer.propose_and_wait(entry).await?;
        Ok(())
    }
}

#[cfg(test)]