Struct CronScheduler 

pub struct CronScheduler { /* private fields */ }

调度器根级 re-export（供 core 内部 dogfood 使用）

Implementations

impl CronScheduler

pub fn new() -> CronScheduler

pub fn parse_cron(&self, expr: &str) -> Result<CronExpr, SchedulerError>

pub fn next_run_time( &self, expr: &str, from: DateTime<Utc>, ) -> Result<DateTime<Utc>, SchedulerError>

pub fn register_handler( &self, task_id: impl Into<String>, handler: Arc<dyn JobHandler>, )

Registers a JobHandler for the given task id. When the scheduler fires a matching task, it looks up the handler by task id. If no handler is registered, the task is skipped silently.

pub fn try_fire_due(&self, now: DateTime<Utc>) -> usize

Fires every enabled task whose cron expression matches now. Returns the number of tasks that fired (and whose handler, if any, returned Ok(())). Errors from individual handlers are recorded but do not abort iteration.

pub fn start(&self, tick_ms: u64) -> Result<(), SchedulerError>

Starts a background worker thread that wakes up every tick_ms milliseconds, queries the current UTC time, and invokes try_fire_due. Calling start while a worker is already running returns an error.

pub fn stop(&self) -> Result<(), SchedulerError>

Stops the background worker thread and waits for it to exit. If no worker is running, this is a no-op.

pub fn is_running(&self) -> bool

Returns true if a background worker is currently running.

Trait Implementations

impl Default for CronScheduler

fn default() -> CronScheduler

Returns the “default value” for a type.

impl Scheduler for CronScheduler

fn schedule(&self, task: ScheduledTask) -> Result<(), SchedulerError>

fn cancel(&self, task_id: &str) -> Result<(), SchedulerError>

fn pause(&self, task_id: &str) -> Result<(), SchedulerError>

fn resume(&self, task_id: &str) -> Result<(), SchedulerError>

fn list_tasks(&self) -> Vec<ScheduledTask>