Struct lightspeed_scheduler::JobExecutor

pub struct JobExecutor { /* private fields */ }

Implementations

impl JobExecutor

pub fn new_with_local_tz() -> JobExecutor

Creates a new Executor that uses the Local time zone for the execution times evaluation. For example, the cron expressions will refer to the Local time zone.

pub fn new_with_utc_tz() -> JobExecutor

Creates a new Executor that uses the UTC time zone for the execution times evaluation. For example, the cron expressions will refer to the UTC time zone.

pub fn new_with_tz(timezone: Option<Tz>) -> JobExecutor

Creates a new Executor that uses a custom time zone for the execution times evaluation. For example, the cron expressions will refer to the specified time zone.

pub async fn add_job( &self, schedule: &dyn TryToScheduler, job: Job ) -> Result<(), SchedulerError>

Adds a job to the JobExecutor.

pub async fn add_job_with_multi_schedule( &self, schedule: &[&dyn TryToScheduler], job: Job ) -> Result<(), SchedulerError>

Adds a job to the JobExecutor.

pub async fn add_job_with_scheduler<S: Into<Scheduler>>( &self, schedule: S, job: Job )

Adds a job to the JobExecutor.

pub async fn run(&self) -> Result<JoinHandle<()>, SchedulerError>

Starts the JobExecutor

pub async fn stop(&self, graceful: bool) -> Result<(), SchedulerError>

Stops the JobExecutor

pub fn set_sleep_between_checks(&self, sleep: Duration)

Sets the sleep time between checks for pending Jobs. The default is 1 second.

Trait Implementations

impl Clone for JobExecutor

fn clone(&self) -> JobExecutor

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.