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

use crate::task::model::task::JobTaskInfo;
use std::collections::BTreeMap;
use std::sync::Arc;

pub struct JobTaskLogGroup {
    pub task_log_map: BTreeMap<u64, Arc<JobTaskInfo>>,
}

impl JobTaskLogGroup {
    pub fn new() -> Self {
        JobTaskLogGroup {
            task_log_map: BTreeMap::new(),
        }
    }

    pub fn update_task_log(&mut self, new_task_log: Arc<JobTaskInfo>, limit_count: usize) {
        if let Some(task_log) = self.task_log_map.get_mut(&new_task_log.task_id) {
            *task_log = new_task_log;
        } else {
            self.task_log_map.insert(new_task_log.task_id, new_task_log);
            if self.task_log_map.len() > limit_count {
                self.task_log_map.pop_first();
            }
        }
    }
}