Struct QueueConfig 

pub struct QueueConfig {
    pub default_queue: String,
    pub max_concurrent_jobs: usize,
    pub sleep_duration: Duration,
    pub visibility_timeout: Duration,
}

Queue system configuration.

Fields

default_queue: String

Default queue name.

max_concurrent_jobs: usize

Maximum number of concurrent jobs per worker.

sleep_duration: Duration

How long to sleep between poll cycles when no jobs are available.

visibility_timeout: Duration

How long a claimed job stays invisible before being reclaimed by the reaper.

Implementations

impl QueueConfig

pub fn from_env() -> Self

Create configuration from environment variables.

Reads the following environment variables:

• QUEUE_CONNECTION: “sync” disables the DB worker loop (defaults to “sync”)
• QUEUE_DEFAULT: Default queue name (defaults to “default”)
• QUEUE_MAX_CONCURRENT: Max concurrent jobs per worker (defaults to 10)
• QUEUE_VISIBILITY_TIMEOUT_SECS: Seconds before claimed jobs are reclaimed (defaults to 300)

Example

use ferro_queue::QueueConfig;

// In bootstrap.rs
let config = QueueConfig::from_env();

pub fn is_sync_mode() -> bool

Check if sync queue mode is configured.

When QUEUE_CONNECTION=sync, jobs are processed immediately in the calling process instead of being written to the database.

pub fn default_queue(self, queue: impl Into<String>) -> Self

Set the default queue name.

pub fn max_concurrent_jobs(self, count: usize) -> Self

Set max concurrent jobs.

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

Set the sleep duration between poll cycles.

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

Set the visibility timeout for claimed jobs.

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

Formats the value using the given formatter.

impl Default for QueueConfig

fn default() -> Self

Returns the “default value” for a type.