Struct WorkerBuilder 

pub struct WorkerBuilder<Q: QueueSet, B: Backend> { /* private fields */ }

Configures a Worker. Created by Worker::builder.

Implementations

impl<Q: QueueSet, B: Backend> WorkerBuilder<Q, B>

pub fn handler<H>(self, handler: H) -> Self

where H: JobHandler, H::Job: Job<Queue = Q>,

Register a handler.

The H::Job: Job<Queue = Q> bound is what makes the worker type-safe: a handler for a job belonging to another queue set does not compile.

pub fn queues(self, queues: &[Q]) -> Self

Consume only these queues instead of every queue in Q. Duplicates are ignored.

pub fn concurrency(self, concurrency: usize) -> Self

Cap the number of jobs running at the same time.

Defaults to the sum of the prefetch of the consumed queues. 0 is treated as 1.

pub fn job_timeout(self, timeout: Duration) -> Self

Abort a handler that runs longer than timeout and treat it as a retryable failure.

pub fn close_backend_on_shutdown(self, close: bool) -> Self

Close the backend when Worker::run returns. Defaults to false.

The backend is an Arc that is normally shared with a crate::Producer (and possibly other workers), so closing it is the caller’s decision: a worker that closed it on its own would take those down with it. Turn this on for a process whose only job is to run this worker, or call backend.close() yourself once run() has returned.

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

Declare the queues and produce the Worker.

Fails with Error::DuplicateHandler if two handlers claim the same Job::NAME.