Struct WorkerBuilder

pub struct WorkerBuilder<'a, CONTEXT>
where
    CONTEXT: Send + Sync + Debug + Clone + 'static,
{ /* private fields */ }

A builder object for a Worker.

Implementations

impl<'a, CONTEXT> WorkerBuilder<'a, CONTEXT>

where CONTEXT: Send + Sync + Debug + Clone + 'static,

pub fn new(queue: &'a Queue, context: CONTEXT) -> Self

Create a new WorkerBuilder for a particular Queue.

pub fn registry(self, registry: &'a JobRegistry<CONTEXT>) -> Self

Get the job definitions from this JobRegistry.

pub fn jobs(self, jobs: impl Into<Vec<JobRunner<CONTEXT>>>) -> Self

Get the job definitions from this list of JobRunners.

pub fn limit_job_types(self, job_types: &[impl AsRef<str>]) -> Self

Limit this worker to only running these job types, even if the registry contains more types.

pub fn min_concurrency(self, min_concurrency: u16) -> Self

Set the minimum concurrency for this worker. When the number of running jobs falls below this number, the worker will try to fetch more jobs, up to max_concurrency. Defaults to the same as max_concurrency.

pub fn max_concurrency(self, max_concurrency: u16) -> Self

The maximum number of jobs that the worker will run concurrently. Defaults to 1.

pub async fn build(self) -> Result<Worker>

Consume this WorkerBuilder and create a new Worker. The Worker must be stored, as it will automatically disconnect from the Queue when it is dropped.