pub async fn initialize_from_single_node(&self, node: NodeId) -> Result<()> {
        tracing::info!({ node }, "initializing cluster from single node");
        let rt = self.routing_table.read().await;
        let members: BTreeSet<NodeId> = rt.keys().cloned().collect();
        rt.get(&node)
            .ok_or_else(|| anyhow!("node {} not found in routing table", node))?
            .0
            .initialize(members.clone())
            .await?;
        Ok(())
    }
/// Initialize all nodes based on the config in the routing table.
Initialize all nodes based on the config in the routing table.
Initialize all nodes based on the config in the routing table .
pub async fn initialize_from_single_node(&self, node: NodeId) -> Result<()> {
        tracing::info!({ node }, "initializing cluster from single node");
        let rt = self.routing_table.read().await;
        let members: BTreeSet<NodeId> = rt.keys().cloned().collect();
        rt.get(&node)
            .ok_or_else(|| anyhow!("node {} not found in routing table", node))?
            .0
            .initialize(members.clone())
            .await?;
        Ok(())
    }
pub async fn initialize_from_single_node ( & self , node : NodeId ) -> Result < ( ) > { tracing :: info ! ( { node } " " ) ; let rt = self . routing_table . read ( ) . await ; let members : BTreeSet < NodeId > = rt . keys ( ) . cloned ( ) . collect ( ) ; rt . get ( & node ) . ok_or_else ( | | anyhow ! ( " " node ) ) ? . 0 . initialize ( members . clone ( ) ) . await ? ; Ok ( ( ) ) }
Initialize all nodes based on the config in the routing table.
Initialize all nodes based on the config in the routing table .
&self
node
NodeId
&self
node
NodeId