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

use std::sync::Arc;

use actix_web::{http::header, web, HttpResponse, Responder};

use crate::common::appdata::AppShareData;

use super::model::{cluster_model::ClusterNodeInfo, ConsoleResult};

pub async fn query_cluster_info(app: web::Data<Arc<AppShareData>>) -> impl Responder {
    let nodes = app.naming_node_manage.get_all_valid_nodes().await.unwrap();
    let leader_node = app.raft.current_leader().await;
    let mut list = vec![];
    for node in nodes {
        let mut node_info: ClusterNodeInfo = node.into();
        if let Some(leader_node) = &leader_node {
            if node_info.node_id == *leader_node {
                node_info.raft_leader = true;
            }
        }
        if app.sys_config.raft_node_id == node_info.node_id {
            node_info.current_node = true;
        }
        list.push(node_info);
    }
    let resp = ConsoleResult::success(list);
    let v = serde_json::to_string(&resp).unwrap();
    HttpResponse::Ok()
        .insert_header(header::ContentType(mime::APPLICATION_JSON))
        .body(v)
}