Method execute

nodedb-cluster/src/migration_executor/executor.rs:105–187

(&self, req: MigrationRequest)

    }

    pub async fn execute(&self, req: MigrationRequest) -> Result<MigrationResult> {
        let source_group = {
            let routing = self.routing.read().unwrap_or_else(|p| p.into_inner());
            routing.group_for_vshard(req.vshard_id)?
        };

        if let Some(state_table) = &self.migration_state {
            let guard = state_table.lock().unwrap_or_else(|p| p.into_inner());
            for row in guard.all_checkpoints() {
                if let Some(_id) = row.migration_uuid() {
                    let vshard_matches = match &row.payload {
                        MigrationCheckpointPayload::AddLearner { vshard_id, .. } => {
                            *vshard_id == req.vshard_id
                        }
                        MigrationCheckpointPayload::CatchUp { vshard_id, .. } => {
                            *vshard_id == req.vshard_id
                        }
                        MigrationCheckpointPayload::PromoteLearner { vshard_id, .. } => {
                            *vshard_id == req.vshard_id
                        }
                        MigrationCheckpointPayload::LeadershipTransfer { vshard_id, .. } => {
                            *vshard_id == req.vshard_id
                        }
                        MigrationCheckpointPayload::Cutover { vshard_id, .. } => {
                            *vshard_id == req.vshard_id
                        }
                        MigrationCheckpointPayload::Complete { vshard_id, .. } => {
                            *vshard_id == req.vshard_id
                        }
                    };
                    if vshard_matches && row.payload.phase_tag() != MigrationPhaseTag::Complete {
                        return Err(ClusterError::MigrationInProgress {
                            vshard_id: req.vshard_id,
                        });
                    }
                }
            }
        }

        let migration_id = Uuid::new_v4();

        let mut state = MigrationState::new(
            req.vshard_id,
            source_group,
            source_group,
            req.source_node,
            req.target_node,
            req.write_pause_budget_us,
        );

        info!(
            vshard = req.vshard_id,
            source = req.source_node,
            target = req.target_node,
            group = source_group,
            migration_id = %migration_id,
            "starting vShard migration"
        );