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

use crate::openapi::xxljob::model::SUCCESS_CODE;
use serde::{Deserialize, Serialize};
use std::sync::Arc;

#[derive(Debug, Serialize, Deserialize, Default, Clone)]
#[serde(rename_all = "camelCase")]
pub struct RegistryParam {
    pub registry_group: Arc<String>,
    pub registry_key: Arc<String>,
    pub registry_value: Arc<String>,
}

#[derive(Debug, Serialize, Deserialize, Default, Clone)]
#[serde(rename_all = "camelCase")]
pub struct CallbackParam {
    pub log_id: u64,
    #[serde(rename(serialize = "logDateTim", deserialize = "logDateTim"))]
    pub log_date_time: i64,
    pub handle_code: i32,
    pub handle_msg: Option<Arc<String>>,
}

impl From<CallbackParam> for crate::task::model::task::TaskCallBackParam {
    fn from(value: CallbackParam) -> Self {
        Self {
            task_id: value.log_id,
            task_date_time: value.log_date_time,
            success: value.handle_code == SUCCESS_CODE,
            handle_msg: value.handle_msg,
        }
    }
}