Struct lightspeed_scheduler::job::Job

pub struct Job { /* fields omitted */ }

Implementations

impl Job

pub fn new<G: Into<String>, N: Into<String>, F: 'static + Send + 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.