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.

pub fn try_fire_due_tracked( &self, now: DateTime<Utc>, tracker: &TaskExecutionTracker, ) -> usize

Trigger all due tasks and record execution results to tracker.

Difference from try_fire_due: this method records execution status after each task trigger (Succeeded / Failed / Skipped), for subsequent task health queries.

pub fn get_task_count(&self) -> usize

Returns total number of registered tasks.

pub fn get_enabled_task_count(&self) -> usize

Returns number of enabled tasks.

pub fn get_task_priorities(&self) -> Vec<(String, i32)>

Returns (id, priority) list of all tasks, sorted by priority descending.

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>