Struct QueueOptions 

pub struct QueueOptions {
    pub workers: usize,
    pub poll_interval: Duration,
    pub stale_minutes: i32,
    pub heartbeat_interval: Duration,
    pub max_attempts: i32,
    pub retry_backoff: Duration,
    pub retention_days: i32,
    pub maintenance_interval: Duration,
}

Queue tuning.

Fields

workers: usize

Concurrent job loops, so the most jobs this process runs at once.

poll_interval: Duration

Sleep between polls of an empty queue, and between schedule ticks.

stale_minutes: i32

A running job not heard from for this many minutes is assumed lost with its worker.

heartbeat_interval: Duration

How often a running job reports in. Keep it well under stale_minutes.

max_attempts: i32

Tries a job gets, including the first, unless it has its own limit. One means no retries.

retry_backoff: Duration

The wait before the first retry.

retention_days: i32

Days to keep finished and cancelled rows.

maintenance_interval: Duration

How often to recover stale jobs and delete old rows.

Trait Implementations

impl Clone for QueueOptions

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 QueueOptions

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

Formats the value using the given formatter.

impl Default for QueueOptions

fn default() -> Self

Returns the “default value” for a type.