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
use actix_web::web;
//use super::{cache, db::kvapi};
//use crate::{raft::cluster::routeapi, user};
pub mod core;
pub mod factory;
pub mod management;
pub mod raft;
pub fn raft_config(config: &mut web::ServiceConfig) {
let scope = web::scope("/nacos/v1/raft")
//.service(web::resource("/vote").route(web::post().to(raft::vote)))
//.service(web::resource("/append").route(web::post().to(raft::append)))
//.service(web::resource("/snapshot").route(web::post().to(raft::snapshot)))
//.service(web::resource("/init").route(web::post().to(management::init)))
//.service(web::resource("/add-learner").route(web::post().to(management::add_learner)))
.service(web::resource("/joinnode").route(web::post().to(management::join_learner)))
.service(
web::resource("/change-membership")
.route(web::post().to(management::change_membership)),
)
.service(web::resource("/metrics").route(web::get().to(management::metrics)))
.service(web::resource("/close-write").route(web::post().to(management::close_write)));
#[cfg(feature = "debug")]
let scope = scope
.service(web::resource("/inject-error").route(web::post().to(management::inject_error)));
config.service(scope);
// for debug
// .service(web::resource("/route").route(web::post().to(routeapi::route_request)))
// .service(web::resource("/table/set").route(web::post().to(kvapi::set)))
// .service(web::resource("/table/get").route(web::get().to(kvapi::get)))
// .service(web::resource("/user/add").route(web::post().to(user::api::add_user)))
// .service(web::resource("/user/update").route(web::post().to(user::api::update_user)))
// .service(web::resource("/user/check").route(web::post().to(user::api::check_user)))
// .service(web::resource("/user/get").route(web::get().to(user::api::get_user)))
// .service(
// web::resource("/user/querypage")
// .route(web::get().to(user::api::get_user_page_list)),
// )
// .service(web::resource("/cache/set").route(web::post().to(cache::api::set_cache)))
// .service(web::resource("/cache/remove").route(web::post().to(cache::api::remove_cache)))
// .service(web::resource("/cache/get").route(web::get().to(cache::api::get_cache))),
}