Struct background_jobs_core::ProcessorMap

pub struct ProcessorMap { /* private fields */ }

A type for storing the relationships between processor names and the processor itself

Processors must be registered with the ProcessorMap in the initialization phase of an application before workers are spawned in order to handle queued jobs.

Implementations

impl ProcessorMap

pub fn new() -> Self

Intialize a ProcessorMap

pub fn register_processor<P>(&mut self, processor: P)where
    P: Processor + Send + Sync + 'static,

Register a Processor with this ProcessorMap.

ProcessorMaps are useless if no processors are registerd before workers are spawned, so make sure to register all your processors up-front.

pub fn process_job(
    &self,
    job: JobInfo
) -> impl Future<Item = JobInfo, Error = ()>

Process a given job

This should not be called from outside implementations of a backgoround-jobs runtime. It is intended for internal use.

Trait Implementations

impl Default for ProcessorMap

fn default() -> Self

Returns the “default value” for a type.