Struct woddle::JobRunner

pub struct JobRunner { /* fields omitted */ }

The runner, which holds the jobs and runner configuration

Implementations

impl JobRunner

pub fn new(config: RunnerConfig) -> Self

Creates a new runner based on the given RunnerConfig

pub fn new_with_vec(
    config: RunnerConfig,
    jobs: Vec<impl Job + Send + Sync + Clone + 'static>
) -> Self

Creates a new runner based on the given RunnerConfig and vector of jobs

pub fn add_job(self, job: impl Job + Send + Sync + Clone + 'static) -> Self

Adds a job to the Runner

pub async fn start(self) -> Result<(), Error>

Starts the runner

This will:

• Validate the added jobs
• Initialize the database state, creating the woddle_jobs table
• Announce all registered jobs with their timers
• Start checking and running jobs