rnacos 0.8.3

Nacos server re-implemented in Rust.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37

use crate::raft::filestore::core::FileStore;
use async_raft_ext::raft::ClientWriteRequest;
use async_raft_ext::{Raft, RaftStorage};

use self::network::core::RaftRouter;
use self::store::{ClientRequest, ClientResponse};

pub mod cache;
pub mod cluster;
pub mod db;
pub mod filestore;
pub mod network;
pub mod store;

pub type NacosRaft = Raft<ClientRequest, ClientResponse, RaftRouter, FileStore>;

pub async fn join_node(
    raft: &NacosRaft,
    raft_store: &FileStore,
    node_id: u64,
) -> anyhow::Result<()> {
    let membership = raft_store.get_membership_config().await?;
    if !membership.contains(&node_id) {
        let mut all_node = membership.all_nodes();
        if all_node.contains(&node_id) {
            return Ok(());
        }
        all_node.insert(node_id);
        let members = all_node.clone().into_iter().collect();
        log::info!("join_node membership,{:?}", &all_node);
        raft.change_membership(all_node).await.ok();
        raft.client_write(ClientWriteRequest::new(ClientRequest::Members(members)))
            .await
            .unwrap();
    }
    Ok(())
}