qrush 0.6.0

Lightweight Job Queue and Task Scheduler for Rust (Actix + Redis + Cron)
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
39
40
41
42

// src/cron/cron_job.rs
use async_trait::async_trait;
use serde::{Deserialize, Serialize};
use crate::job::Job;
/// NOTE: `timezone()` must return a valid IANA TZ (e.g., "UTC", "Asia/Kolkata")

/// Trait for jobs that can be scheduled with cron expressions
#[async_trait]
pub trait CronJob: Job + Send + Sync {
    /// Cron expression (e.g., "0 */5 * * * *" for every 5 minutes)
    fn cron_expression(&self) -> &'static str;
    
    /// Unique identifier for this cron job
    fn cron_id(&self) -> &'static str;
    
    /// Whether this cron job is enabled
    fn enabled(&self) -> bool {
        true
    }
    
    /// Timezone for cron execution (default UTC)
    fn timezone(&self) -> &'static str {
        "UTC"
    }
}

/// Metadata for storing cron jobs in Redis
#[derive(Debug, Serialize, Deserialize, Clone)]
pub struct CronJobMeta {
    pub id: String,
    pub name: String,
    pub queue: String,
    pub cron_expression: String,
    pub timezone: String,
    pub enabled: bool,
    /// RFC3339 (UTC). May be absent on first run.
    #[serde(default)]
    pub last_run: Option<String>,
    pub next_run: String,
    pub created_at: String,
    pub payload: String, // Serialized job data
}