Struct QueueConfig 

pub struct QueueConfig {
    pub db_path: Option<PathBuf>,
    pub worker_id: String,
    pub cooldown: Duration,
    pub max_consecutive: u32,
    pub poll_interval: Duration,
    pub heartbeat_interval: Duration,
    pub stale_after: Duration,
    pub max_retries: u32,
}

Configuration for the queue system.

Use QueueConfig::builder() for ergonomic construction, or QueueConfig::default() for sensible defaults (in-memory DB, no cooldown).

Fields

db_path: Option<PathBuf>

Path to SQLite database file. None = in-memory database.

worker_id: String

Stable worker identifier used for leases, heartbeats, and diagnostics.

cooldown: Duration

Cooldown duration between job executions (0 = no cooldown).

max_consecutive: u32

Maximum consecutive jobs before a forced cooldown (0 = unlimited).

poll_interval: Duration

Polling interval for checking pending jobs.

heartbeat_interval: Duration

Interval between lease heartbeats while a job is running.

stale_after: Duration

Visibility timeout / stale lease threshold for reclaiming jobs.

max_retries: u32

Maximum retry attempts for retryable failures.

Implementations

impl QueueConfig

pub fn builder() -> QueueConfigBuilder

Start building a config with the builder pattern.

Trait Implementations

impl Clone for QueueConfig

fn clone(&self) -> QueueConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueueConfig

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

Formats the value using the given formatter.

impl Default for QueueConfig

fn default() -> QueueConfig

Returns the “default value” for a type.