Struct WorkerConfig 

pub struct WorkerConfig {
    pub concurrency: usize,
    pub poll_interval: Duration,
    pub job_timeout: Duration,
    pub visibility_timeout: Option<Duration>,
    pub log_execution: bool,
}

Worker configuration.

Fields

concurrency: usize

Number of concurrent jobs to process

poll_interval: Duration

Poll interval for checking new jobs

job_timeout: Duration

Timeout for job execution

visibility_timeout: Option<Duration>

How long an in-flight claim may go unresolved before the reaper assumes the worker holding it died and returns the job to its pending queue.

dequeue records a claim in the queue’s processing set; nothing else resolves it if the worker crashes, is SIGKILLed, or its handler task panics, so without a reaper such a job is stranded in no queue at all and is never retried. Worker::start runs Queue::reclaim_stale with this timeout in the background.

Must comfortably exceed job_timeout (the default is twice it), or a merely slow job is re-filed while still running and executes twice. None disables reaping entirely — only appropriate when some other process reaps the same queue.

log_execution: bool

Whether to log job execution

Trait Implementations

impl Clone for WorkerConfig

fn clone(&self) -> WorkerConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for WorkerConfig

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

Formats the value using the given formatter.

impl Default for WorkerConfig

fn default() -> Self

Returns the “default value” for a type.