forge_core/cron/
traits.rs

1use std::future::Future;
2use std::pin::Pin;
3
4use super::context::CronContext;
5use super::schedule::CronSchedule;
6use crate::Result;
7
8/// Trait for cron job handlers.
9pub trait ForgeCron: Send + Sync + 'static {
10    /// Get cron metadata.
11    fn info() -> CronInfo;
12
13    /// Execute the cron job.
14    fn execute(ctx: &CronContext) -> Pin<Box<dyn Future<Output = Result<()>> + Send + '_>>;
15}
16
17/// Cron job metadata.
18#[derive(Debug, Clone)]
19pub struct CronInfo {
20    /// Cron name (function name).
21    pub name: &'static str,
22    /// Cron schedule expression.
23    pub schedule: CronSchedule,
24    /// Timezone for the schedule.
25    pub timezone: &'static str,
26    /// Whether to catch up missed runs.
27    pub catch_up: bool,
28    /// Maximum number of missed runs to catch up.
29    pub catch_up_limit: u32,
30    /// Timeout for execution.
31    pub timeout: std::time::Duration,
32}
33
34impl Default for CronInfo {
35    fn default() -> Self {
36        Self {
37            name: "",
38            schedule: CronSchedule::default(),
39            timezone: "UTC",
40            catch_up: false,
41            catch_up_limit: 10,
42            timeout: std::time::Duration::from_secs(3600),
43        }
44    }
45}
46
47#[cfg(test)]
48#[allow(clippy::unwrap_used, clippy::indexing_slicing)]
49mod tests {
50    use super::*;
51
52    #[test]
53    fn test_cron_info_default() {
54        let info = CronInfo::default();
55        assert_eq!(info.name, "");
56        assert_eq!(info.timezone, "UTC");
57        assert!(!info.catch_up);
58        assert_eq!(info.catch_up_limit, 10);
59    }
60}
forge_core/cron/traits.rs

forge_core/cron/
traits.rs
