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
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65

use std::sync::Arc;

use actix_web::{
    web::{self, Data, Json},
    Responder,
};
use serde::{Deserialize, Serialize};

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

use super::table::{TableManagerQueryReq, TableManagerReq, TableManagerResult};

#[derive(Debug, Deserialize)]
pub struct KvOpParam {
    pub table_name: Arc<String>,
    pub key: String,
    pub value: Option<String>,
}

#[derive(Debug, Deserialize, Serialize)]
pub struct KvValueResult {
    pub success: bool,
    pub value: String,
}

pub async fn set(
    app: Data<Arc<AppShareData>>,
    web::Form(param): web::Form<KvOpParam>,
) -> actix_web::Result<impl Responder> {
    app.raft_table_route
        .request(TableManagerReq::Set {
            table_name: param.table_name,
            key: param.key.as_bytes().to_owned(),
            value: param.value.unwrap_or_default().as_bytes().to_owned(),
            last_seq_id: None,
        })
        .await
        .unwrap();
    Ok("{\"ok\":1}")
}

pub async fn get(
    app: Data<Arc<AppShareData>>,
    web::Query(param): web::Query<KvOpParam>,
) -> actix_web::Result<impl Responder> {
    let res: TableManagerResult = app
        .raft_table_manage
        .send(TableManagerQueryReq::Get {
            table_name: param.table_name,
            key: param.key,
        })
        .await
        .unwrap()
        .unwrap();
    match res {
        TableManagerResult::Value(value) => Ok(Json(KvValueResult {
            value: String::from_utf8(value).unwrap(),
            success: true,
        })),
        _ => Ok(Json(KvValueResult {
            value: "not found key value".to_owned(),
            success: false,
        })),
    }
}