Struct CronScheduler

pub struct CronScheduler {
    scheduler: JobScheduler,
    storage: Arc<Storage>,
    executor: Arc<WorkflowExecutor>,
    job_map: Arc<RwLock<HashMap<Uuid, String>>>,
}

Cron scheduler responsible for managing all scheduled jobs

Features:

• Supports standard cron expressions
• Supports timezone configuration
• Automatically triggers workflow execution
• Persists job mapping relationships

Fields

scheduler: JobScheduler

tokio-cron-scheduler instance

storage: Arc<Storage>

Storage layer used to fetch workflows

executor: Arc<WorkflowExecutor>

Workflow executor

job_map: Arc<RwLock<HashMap<Uuid, String>>>

job_uuid -> trigger_id mapping table (used for job removal)

Implementations

impl CronScheduler

pub async fn new( storage: Arc<Storage>, executor: Arc<WorkflowExecutor>, ) -> Result<Self>

Create a new Cron scheduler

pub async fn start(&self) -> Result<()>

Start the scheduler

pub async fn add_schedule( &self, trigger: &ActiveTrigger, cron_expr: String, timezone: Option<String>, payload: Option<Value>, ) -> Result<()>

Add a scheduled job

Parameters

• trigger: active trigger information
• cron_expr: 6-field cron expression (sec min hour day month weekday), e.g. “0 0 0 * * *” for midnight every day
• timezone: timezone (e.g. “Asia/Shanghai”), None indicates UTC
• payload: payload passed to the workflow when triggered

pub async fn remove_schedule(&self, trigger_id: &str) -> Result<bool>

Remove a scheduled job

Returns Ok(true) when a job was found and removed, Ok(false) when no job existed, and Err if the underlying scheduler operation failed.

pub async fn shutdown(&mut self) -> Result<()>

Shut down the scheduler

pub async fn active_job_count(&self) -> usize

Get the number of active jobs