Struct lightspeed_scheduler::job::Job

pub struct Job { /* private fields */ }

Implementations

impl Job

pub fn new<G: Into<String>, N: Into<String>, F: 'static + Send + Sync + Fn() -> Pin<Box<dyn Future<Output = Result<(), Box<dyn Error + Send + Sync>>> + Send>>>( group: G, name: N, retries_after_failure: Option<u64>, function: F ) -> Self

pub async fn is_running(&self) -> bool

Returns true if this job is currently running.

pub fn name(&self) -> &str

pub fn group(&self) -> &str

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

Run the job immediately and re-schedule it.