Struct JobRegistry 

pub struct JobRegistry { /* private fields */ }

Owns jobs and drives their schedules.

Add jobs with add_job, start all schedules with start, and release resources with stop. Periodic legs run as Tokio interval tasks; Exact legs are cron entries (PeriodicAndExact daily leg fires on day 1 of each month).

Implementations

impl JobRegistry

pub fn new() -> Self

Creates an empty registry with no scheduler running.

pub fn get_runs(&self, name: &str) -> Option<usize>

Returns the total number of runs of a job.

pub fn get_failures(&self, name: &str) -> Option<usize>

Returns the number of successful runs of a job.

pub fn get_successes(&self, name: &str) -> Option<usize>

Returns the number of successful runs of a job.

pub fn add_job<J: ServiceJob + 'static>(&mut self, job: J)

Adds a job to the registry. The job runs once start is called.

J is the concrete ServiceJob implementation being stored.

pub fn job_count(&self) -> usize

Returns the number of jobs in the registry.

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

Starts the scheduler and all configured job legs.

Periodic jobs without a period default to 60 seconds; Exact legs without a schedule are skipped. Failures of individual runs are logged and do not stop the schedule. Returns an error if the scheduler cannot start.

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

Stops every job gracefully and shuts down the scheduler, if running.

Returns the first error raised by a job’s graceful stop or by shutdown.

Trait Implementations

impl Default for JobRegistry

fn default() -> Self

Returns the “default value” for a type.