Method run

nodedb-cluster/src/decommission/coordinator.rs:71–91

Propose every entry in the plan sequentially, waiting for each commit. Returns the total number of entries committed and the final applied index.

(self)

    /// each commit. Returns the total number of entries committed
    /// and the final applied index.
    pub async fn run(self) -> Result<DecommissionRunResult> {
        let node_id = self.plan.node_id;
        let total = self.plan.entries.len();
        info!(node_id, steps = total, "decommission coordinator starting");
        let mut last_applied = 0u64;
        for (step, entry) in self.plan.entries.into_iter().enumerate() {
            debug!(node_id, step, total, "proposing decommission entry");
            last_applied = self.proposer.propose_and_wait(entry).await?;
        }
        info!(
            node_id,
            entries_committed = total,
            last_applied,
            "decommission coordinator finished"
        );
        Ok(DecommissionRunResult {
            node_id,
            entries_committed: total,
            last_applied_index: last_applied,
        })
    }
}

#[cfg(test)]