Struct JobConfig 

#[non_exhaustive]
pub struct JobConfig {
    pub poll_interval_secs: u64,
    pub stale_threshold_secs: u64,
    pub stale_reaper_interval_secs: u64,
    pub drain_timeout_secs: u64,
    pub queues: Vec<QueueConfig>,
    pub cleanup: Option<CleanupConfig>,
    pub database: Option<Config>,
}

Top-level configuration for the job worker.

Deserializes from YAML under the job key. All fields have defaults so an empty config block is valid.

Defaults

Field	Default
poll_interval_secs	1
stale_threshold_secs	600 (10 min)
stale_reaper_interval_secs	60 (1 min)
drain_timeout_secs	30
queues	one "default" queue with concurrency 4
cleanup	enabled, 1 h interval, 72 h retention

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

poll_interval_secs: u64

How often the worker polls the database for new jobs, in seconds.

stale_threshold_secs: u64

Jobs stuck in running for longer than this many seconds are considered stale and reset to pending by the reaper.

stale_reaper_interval_secs: u64

How often the stale reaper runs, in seconds.

drain_timeout_secs: u64

Maximum time in seconds to wait for in-flight jobs to finish during graceful shutdown.

queues: Vec<QueueConfig>

Queue definitions. Defaults to a single "default" queue.

cleanup: Option<CleanupConfig>

Optional periodic cleanup of terminal jobs. Set to None to disable.

database: Option<Config>

Separate SQLite database for the job queue. When set, the job worker uses this pool instead of the main application database, keeping job-queue writes from contending with app queries.

Trait Implementations

impl Clone for JobConfig

fn clone(&self) -> JobConfig

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for JobConfig

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

Formats the value using the given formatter.

impl Default for JobConfig

fn default() -> Self

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for JobConfig

where JobConfig: Default,

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.