ratchjob 0.2.1

一个rust实现的分布式任务调度平台服务。计划完全兼容xxl-job协议，然后再增强一些任务调度平台能力。
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

pub mod app_api;
pub mod job_api;
pub mod model;
pub mod raft_api;

use crate::web_config::about_info;
use actix_web::web;
use actix_web::web::ServiceConfig;

pub fn v1_api_config(config: &mut ServiceConfig) {
    // /api/v1 后续计划废弃
    config.service(
        web::scope("/api/v1")
            .service(
                web::resource("/app/instance/addrs")
                    .route(web::get().to(app_api::query_app_instance_addrs)),
            )
            .service(web::resource("/job/create").route(web::post().to(job_api::create_job)))
            .service(web::resource("/job/update").route(web::post().to(job_api::update_job)))
            .service(web::resource("/job/info").route(web::get().to(job_api::get_job_info)))
            .service(web::resource("/job/list").route(web::get().to(job_api::query_job_list)))
            .service(web::resource("/job/export").route(web::get().to(job_api::export_jobs)))
            .service(web::resource("/job/import").route(web::post().to(job_api::import_jobs)))
            .service(
                web::resource("/job/queryIdByKey").route(web::get().to(job_api::get_job_id_by_key)),
            )
            .service(
                web::resource("/job/queryJobByKey")
                    .route(web::get().to(job_api::get_job_info_by_key)),
            )
            .service(web::resource("/raft/metrics").route(web::get().to(raft_api::metrics)))
            .service(web::resource("/about").route(web::get().to(about_info))),
    );
    config.service(
        web::scope("/ratch/v1")
            .service(
                web::resource("/namespace/list")
                    .route(web::get().to(app_api::query_namespace_list)),
            )
            .service(
                web::resource("/app/instance/addrs")
                    .route(web::get().to(app_api::query_app_instance_addrs)),
            )
            .service(
                web::resource("/app/list").route(web::get().to(app_api::query_appname_all_list)),
            )
            .service(web::resource("/job/create").route(web::post().to(job_api::create_job)))
            .service(web::resource("/job/update").route(web::post().to(job_api::update_job)))
            .service(web::resource("/job/remove").route(web::post().to(job_api::remove_job)))
            .service(web::resource("/job/info").route(web::get().to(job_api::get_job_info)))
            .service(web::resource("/job/list").route(web::get().to(job_api::query_job_list)))
            .service(web::resource("/job/export").route(web::get().to(job_api::export_jobs)))
            .service(web::resource("/job/import").route(web::post().to(job_api::import_jobs)))
            .service(
                web::resource("/job/queryIdByKey").route(web::get().to(job_api::get_job_id_by_key)),
            )
            .service(
                web::resource("/job/queryJobByKey")
                    .route(web::get().to(job_api::get_job_info_by_key)),
            )
            .service(
                web::resource("/job/task/list").route(web::get().to(job_api::query_job_task_list)),
            )
            .service(
                web::resource("/job/task/latest-history")
                    .route(web::get().to(job_api::query_latest_task_history)),
            )
            .service(web::resource("/raft/metrics").route(web::get().to(raft_api::metrics)))
            .service(web::resource("/about").route(web::get().to(about_info))),
    );
}