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
use std::time::Duration;

use thiserror::Error;

#[derive(Debug, Error, PartialEq, Eq)]
pub enum LocalQueueConfigError {
    #[error("local_queue.refetch_delay.duration ({duration:?}) must not be larger than poll_interval ({poll_interval:?})")]
    RefetchDelayExceedsPollInterval {
        duration: Duration,
        poll_interval: Duration,
    },
    #[error("local_queue.size must be greater than 0")]
    EmptySize,
    #[error("local_queue.queue_count must be greater than 0")]
    EmptyQueueCount,
    #[error("local_queue.size ({size}) must not exceed i32::MAX ({max})")]
    SizeTooLarge { size: usize, max: i32 },
}