Struct QueueConfigBuilder 

pub struct QueueConfigBuilder { /* private fields */ }

Builder for QueueConfig.

Implementations

impl QueueConfigBuilder

pub fn with_db_path(self, path: PathBuf) -> Self

Set the SQLite database path for persistence. Omit for in-memory.

pub fn with_worker_id(self, worker_id: impl Into<String>) -> Self

Set the worker identifier used for job leases and heartbeats.

pub fn with_cooldown(self, duration: Duration) -> Self

Set the cooldown duration between consecutive job executions.

pub fn with_max_consecutive(self, max: u32) -> Self

Set the maximum consecutive jobs before a forced cooldown.

pub fn with_poll_interval(self, interval: Duration) -> Self

Set the polling interval for checking pending jobs.

pub fn with_heartbeat_interval(self, interval: Duration) -> Self

Set the heartbeat interval for running jobs.

pub fn with_stale_after(self, duration: Duration) -> Self

Set the stale lease threshold for reclaiming abandoned jobs.

pub fn with_max_retries(self, max_retries: u32) -> Self

Set the maximum retry attempts for retryable failures.

pub fn build(self) -> QueueConfig

Build the final QueueConfig.

Trait Implementations

impl Default for QueueConfigBuilder

fn default() -> QueueConfigBuilder

Returns the “default value” for a type.