async fn add_node(&self, node: &Node) {
        match T::new(&node.id).await {
            Ok(node) => {
                let mut registry = self.nodes.lock().await;
                registry.insert(node.id(), node.clone());
            }
            Err(error) => {
                tracing::error!(
                    "Error when adding node '{}': {}",
                    node.id,
                    error
                );
            }
        }
    }
/// Add new node to the registry
Add new node to the registry
Add new node to the registry
async fn add_node(&self, node: &Node) {
        match T::new(&node.id).await {
            Ok(node) => {
                let mut registry = self.nodes.lock().await;
                registry.insert(node.id(), node.clone());
            }
            Err(error) => {
                tracing::error!(
                    "Error when adding node '{}': {}",
                    node.id,
                    error
                );
            }
        }
    }
async fn add_node ( & self , node : & Node ) { match T :: new ( & node . id ) . await { Ok ( node ) => { let mut registry = self . nodes . lock ( ) . await ; registry . insert ( node . id ( ) , node . clone ( ) ) ; } Err ( error ) => { tracing :: error ! ( " " node id error ) ; } } }
Add new node to the registry
Add new node to the registry
&self
node
&Node