Struct crony::Runner

pub struct Runner { /* private fields */ }

Runner that will hold all the jobs and will start up the execution and eventually will stop it.

Implementations

impl Runner

pub fn new() -> Self

Create new runner

Examples found in repository

examples/basic.rs (line 16)

fn main() {
    let mut runner = Runner::new();

    println!("Adding ExampleJob to the Runner");
    runner = runner.add(Box::new(ExampleJob));

    println!("Starting the Runner for 20 seconds");
    runner = runner.run();
    thread::sleep(Duration::from_millis(20 * 1000));

    println!("Stopping the Runner");
    runner.stop();
}

pub fn add(self, job: Box<dyn Job>) -> Self

Add jobs into the runner

panics if you try to push a job onto already started runner

Examples found in repository

examples/basic.rs (line 19)

fn main() {
    let mut runner = Runner::new();

    println!("Adding ExampleJob to the Runner");
    runner = runner.add(Box::new(ExampleJob));

    println!("Starting the Runner for 20 seconds");
    runner = runner.run();
    thread::sleep(Duration::from_millis(20 * 1000));

    println!("Stopping the Runner");
    runner.stop();
}

pub fn jobs_to_run(&self) -> usize

Number of jobs ready to start running

pub fn run(self) -> Self

Start the loop and job execution

Examples found in repository

examples/basic.rs (line 22)

fn main() {
    let mut runner = Runner::new();

    println!("Adding ExampleJob to the Runner");
    runner = runner.add(Box::new(ExampleJob));

    println!("Starting the Runner for 20 seconds");
    runner = runner.run();
    thread::sleep(Duration::from_millis(20 * 1000));

    println!("Stopping the Runner");
    runner.stop();
}

pub fn stop(self)

Stop the spawned runner

Examples found in repository

examples/basic.rs (line 26)

fn main() {
    let mut runner = Runner::new();

    println!("Adding ExampleJob to the Runner");
    runner = runner.add(Box::new(ExampleJob));

    println!("Starting the Runner for 20 seconds");
    runner = runner.run();
    thread::sleep(Duration::from_millis(20 * 1000));

    println!("Stopping the Runner");
    runner.stop();
}

pub fn is_running(&self) -> bool

Lets us know if the cron worker is running

pub fn is_working(&self) -> bool

Lets us know if the worker is in the process of executing a job currently

Trait Implementations

impl Default for Runner

fn default() -> Self

Returns the “default value” for a type.