Method round

nodedb-cluster/src/distributed_graph/wcc.rs:121–137

Produce outbound merge requests for boundary edges.

(&self)

    /// Produce outbound merge requests for boundary edges.
    pub fn round(&self) -> (HashMap<u32, Vec<(String, String)>>, usize) {
        let mut outbound: HashMap<u32, Vec<(String, String)>> = HashMap::new();

        for (&local_id, ghost_list) in &self.boundary_edges {
            let root = find_static(&self.parent, local_id as usize);
            let label = self.global_labels[root].clone();
            for (remote_name, target_shard) in ghost_list {
                outbound
                    .entry(*target_shard)
                    .or_default()
                    .push((remote_name.clone(), label.clone()));
            }
        }

        let sent: usize = outbound.values().map(|v| v.len()).sum();
        (outbound, sent)
    }

    /// Apply incoming merges. Returns number of labels changed.
    pub fn apply_merges(&mut self, merges: &[(String, String)]) -> usize {