Struct JobRegistry 

pub struct JobRegistry { /* private fields */ }

Maps a job’s wire name back to code that can run it.

A worker reads {"name": "mail.welcome", …} and has no idea what type that is; the registry is what closes the gap. Every job type an application dispatches must be registered, or its jobs will fail as unknown.

Implementations

impl JobRegistry

pub fn new() -> Self

An empty registry.

pub fn register<J: Job>(&mut self) -> &mut Self

Register J so the worker can run it.

pub fn with<J: Job>(self) -> Self

Builder form of register.

pub fn knows(&self, name: &str) -> bool

Whether name is registered.

pub fn names(&self) -> Vec<&str>

Every registered job name, sorted.

pub async fn run(&self, job: &QueuedJob, context: Arc<JobContext>) -> Result<()>

Run a queued job.

Trait Implementations

impl Clone for JobRegistry

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for JobRegistry

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for JobRegistry

fn default() -> Self

Returns the “default value” for a type.