Struct QueueConfig 

pub struct QueueConfig { /* private fields */ }

Queue behaviour

Implementations

impl QueueConfig

pub fn new() -> Self

5 attempts, backoff 1 s doubling up to 1 h with +-20 % jitter, nothing persisted, the last 1000 dead jobs kept

pub fn max_attempts(self, n: u32) -> Self

Total tries per job including the first (at least 1)

pub fn base_delay(self, d: Duration) -> Self

Delay before the first retry; it doubles with every failed attempt

pub fn max_delay(self, d: Duration) -> Self

pub fn jitter(self, on: bool) -> Self

Spread retries by +-20 % so that jobs failing together do not retry together

pub fn persist_to(self, path: impl Into<PathBuf>) -> Self

Keep the queue in this JSON file (written atomically after changes)

pub fn dead_letter_limit(self, n: usize) -> Self

How many dead jobs to remember (the oldest are dropped)

pub fn clock(self, clock: impl Fn() -> u64 + Send + Sync + 'static) -> Self

Replace the time source, in milliseconds since the Unix epoch (tests)

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 Default for QueueConfig

fn default() -> Self

Returns the “default value” for a type.