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

use crate::job::core::JobManager;
use crate::metrics::metrics_key::MetricsKey;
use crate::metrics::model::{MetricsItem, MetricsQuery, MetricsRecord};
use actix::{Context, Handler};

impl Handler<MetricsQuery> for JobManager {
    type Result = anyhow::Result<Vec<MetricsItem>>;

    fn handle(&mut self, _msg: MetricsQuery, _ctx: &mut Context<Self>) -> Self::Result {
        let list = vec![
            MetricsItem {
                metrics_type: MetricsKey::JobSize,
                record: MetricsRecord::Gauge(self.job_map.len() as f32),
            },
            MetricsItem {
                metrics_type: MetricsKey::JobEnableSize,
                record: MetricsRecord::Gauge(self.get_all_enable_size() as f32),
            },
        ];
        Ok(list)
    }
}