Struct sqlxmq::JobRegistry

pub struct JobRegistry { /* fields omitted */ }

Stores a mapping from job name to job. Can be used to construct a job runner.

Implementations

impl JobRegistry

pub fn new(jobs: &[&'static NamedJob]) -> Self

Construct a new job registry from the provided job list.

pub fn set_error_handler(
    &mut self,
    error_handler: impl Fn(&str, Box<dyn Error + Send + 'static>) + Send + Sync + 'static
) -> &mut Self

Set a function to be called whenever a job returns an error.

pub fn set_context<C: Clone + Send + Sync + 'static>(
    &mut self,
    context: C
) -> &mut Self

Provide context for the jobs.

pub fn context<C: Clone + Send + Sync + 'static>(&self) -> C

Access job context. Will panic if context with this type has not been provided.

pub fn resolve_job(&self, name: &str) -> Option<&'static NamedJob>

Look-up a job by name.

pub fn default_error_handler(name: &str, error: Box<dyn Error + Send + 'static>)

The default error handler implementation, which simply logs the error.

pub fn runner(self, pool: &Pool<Postgres>) -> JobRunnerOptions

Construct a job runner from this registry and the provided connection pool.