Struct CronScheduler 

pub struct CronScheduler { /* private fields */ }

Cron scheduler that integrates with the virtual clock

Implementations

impl CronScheduler

pub fn new(clock: Arc<VirtualClock>) -> Self

Create a new cron scheduler

pub fn new_with_global_clock() -> Self

Create a new cron scheduler using the global clock

This will use the global virtual clock registry if available, or create a new clock if none is registered.

pub async fn add_job( &self, job: CronJob, action: CronJobAction, ) -> Result<(), String>

Add a cron job

pub async fn remove_job(&self, job_id: &str) -> bool

Remove a cron job

pub async fn get_job(&self, job_id: &str) -> Option<CronJob>

Get a cron job by ID

pub async fn list_jobs(&self) -> Vec<CronJob>

List all cron jobs

pub async fn set_job_enabled( &self, job_id: &str, enabled: bool, ) -> Result<(), String>

Enable or disable a cron job

pub async fn check_and_execute(&self) -> Result<usize, String>

Check for jobs that should execute now and execute them

This should be called periodically (e.g., every second) to check if any jobs are due for execution.

pub fn clock(&self) -> Arc<VirtualClock>

Get the virtual clock