Struct QueueConfig 

pub struct QueueConfig {
    pub name: Option<String>,
    pub concurrency: usize,
    pub priority_range: Option<(i32, i32)>,
}

Configuration for a worker queue

Fields

name: Option<String>

Queue name (None for default queue)

concurrency: usize

Number of concurrent jobs to process in this queue

priority_range: Option<(i32, i32)>

Priority range for jobs in this queue (inclusive)

Implementations

impl QueueConfig

pub fn default_queue(concurrency: usize) -> Self

Create configuration for the default queue

pub fn named_queue(name: impl Into<String>, concurrency: usize) -> Self

Create configuration for a named queue

pub fn priority_queue( name: impl Into<String>, concurrency: usize, min_priority: i32, max_priority: i32, ) -> Self

Create configuration for a priority-based queue

Trait Implementations

impl Clone for QueueConfig

fn clone(&self) -> QueueConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueueConfig

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

Formats the value using the given formatter.