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
66
67
68
69
70
71
72
73
74
75
76
77
78

use crate::openapi::constant::{EMPTY, NAMING_V1_BASE_PATH};
use crate::openapi::naming::catalog::{get_instance_page, query_opt_service_list};
use crate::openapi::naming::instance::{
    beat_instance, del_instance, get_instance, get_instance_list, update_instance,
};
use crate::openapi::naming::operator::{
    mock_get_switches, mock_operator_metrics, mock_put_switches,
};
use crate::openapi::naming::service::{
    query_service, query_service_list, query_subscribers_list, remove_service, update_service,
};
use crate::openapi::RouteConf;
use actix_web::web::{scope, ServiceConfig};
use actix_web::{web, Scope};

mod catalog;
pub(crate) mod instance;
pub mod model;
mod operator;
pub(crate) mod service;
mod v2;

pub fn openapi_service(conf: RouteConf) -> Vec<Scope> {
    vec![openapi_v1_route(conf)]
}

pub fn openapi_v1_route(_conf: RouteConf) -> Scope {
    web::scope(NAMING_V1_BASE_PATH)
        .service(instance::service())
        .service(service::service())
        .service(operator::service())
        .service(catalog::service())
}

pub fn naming_v1_route(config: &mut ServiceConfig) {
    config
        .service(
            scope("/nacos/v1/ns/instance")
                .service(
                    web::resource(EMPTY)
                        .route(web::get().to(get_instance))
                        .route(web::post().to(update_instance))
                        .route(web::put().to(update_instance))
                        .route(web::patch().to(update_instance))
                        .route(web::delete().to(del_instance)),
                )
                .service(beat_instance)
                .service(get_instance_list),
        )
        .service(
            scope("/nacos/v1/ns/service")
                .service(
                    web::resource(EMPTY)
                        .route(web::post().to(update_service))
                        .route(web::put().to(update_service))
                        .route(web::delete().to(remove_service))
                        .route(web::get().to(query_service)),
                )
                .service(web::resource("/list").route(web::get().to(query_service_list)))
                .service(
                    web::resource("/subscribers").route(web::get().to(query_subscribers_list)),
                ),
        )
        .service(
            scope("/nacos/v1/ns/operator")
                .service(
                    web::resource("switches")
                        .route(web::get().to(mock_get_switches))
                        .route(web::put().to(mock_put_switches)),
                )
                .service(mock_operator_metrics),
        )
        .service(
            scope("/nacos/v1/ns/catalog")
                .service(query_opt_service_list)
                .service(web::resource("instances").route(web::get().to(get_instance_page))),
        );
}