Struct QueueConfig 

pub struct QueueConfig {
    pub store: String,
    pub url: Option<String>,
    pub prefix: String,
    pub mode: String,
    pub workers: usize,
    pub queues: Vec<String>,
    pub retry_after_seconds: u64,
    pub poll_seconds: u64,
}

The queue ([queue]): where jobs wait and who runs them.

Fields

store: String

auto, database or redis. auto is database.

url: Option<String>

The Redis URL (redis://host:6379/0) for the redis store.

prefix: String

The prefix of every Redis key, laterite by default.

mode: String

worker (workers in this process), external (another process runs queue work) or inline (a job runs as it is pushed).

workers: usize

How many workers the process runs in worker mode.

queues: Vec<String>

The queues a worker takes from, in priority order.

retry_after_seconds: u64

Seconds after which a claimed job counts as abandoned and is claimed again. Longer than any job’s timeout.

poll_seconds: u64

Seconds an idle worker waits before looking again.

Trait Implementations

impl Clone for QueueConfig

fn clone(&self) -> Self

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.

impl Default for QueueConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for QueueConfig

where QueueConfig: Default,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.