Struct WorkerConfig 

pub struct WorkerConfig {
    pub queues: Vec<String>,
    pub max_jobs: usize,
    pub sleep_duration: Duration,
    pub stop_on_error: bool,
}

Worker configuration.

Fields

queues: Vec<String>

Queues to process (in priority order).

max_jobs: usize

Maximum concurrent jobs.

sleep_duration: Duration

Sleep duration when no jobs are available.

stop_on_error: bool

Whether to stop on error.

Implementations

impl WorkerConfig

pub fn new(queues: Vec<String>) -> Self

Create a new worker config for specific queues.

pub fn max_jobs(self, max: usize) -> Self

Set max concurrent jobs.

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.