graphile_worker 0.13.3

High performance Rust/PostgreSQL job queue (also suitable for getting jobs generated by PostgreSQL triggers/functions out into a different work queue)
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

use std::time::Duration;

use rand::RngExt;

pub(in crate::local_queue) struct RetryOptions {
    pub(in crate::local_queue) max_attempts: u32,
    pub(in crate::local_queue) min_delay_ms: u64,
    pub(in crate::local_queue) max_delay_ms: u64,
    pub(in crate::local_queue) multiplier: f64,
}

pub(in crate::local_queue) const RETURN_JOBS_RETRY_OPTIONS: RetryOptions = RetryOptions {
    max_attempts: 20,
    min_delay_ms: 200,
    max_delay_ms: 30_000,
    multiplier: 1.5,
};

pub(in crate::local_queue) fn calculate_retry_delay(
    attempt: u32,
    options: &RetryOptions,
) -> Duration {
    let base = options.min_delay_ms as f64 * options.multiplier.powi(attempt as i32);
    let capped = base.min(options.max_delay_ms as f64);
    let jittered = capped * (0.5 + rand::rng().random::<f64>() * 0.5);
    Duration::from_millis(jittered as u64)
}