forge-core 0.10.0

Core types and traits for the Forge framework
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

//! Cron scheduler configuration.

use std::time::Duration;

use serde::{Deserialize, Serialize};

use super::types::DurationStr;

/// Cron scheduler configuration.
#[derive(Debug, Clone, Serialize, Deserialize)]
#[non_exhaustive]
pub struct CronConfig {
    /// Poll interval for the cron scheduler tick (e.g. "1s", "5s").
    #[serde(default = "default_poll_interval")]
    pub poll_interval: DurationStr,

    /// Maximum number of catch-up jobs to insert per scheduler tick after
    /// downtime. Prevents burst-inserting thousands of missed jobs.
    #[serde(default = "default_catch_up_limit")]
    pub catch_up_limit: usize,
}

impl Default for CronConfig {
    fn default() -> Self {
        Self {
            poll_interval: default_poll_interval(),
            catch_up_limit: default_catch_up_limit(),
        }
    }
}

fn default_poll_interval() -> DurationStr {
    DurationStr::new(Duration::from_secs(1))
}

fn default_catch_up_limit() -> usize {
    100
}