Struct apalis_core::storage::builder::WorkerConfig

pub struct WorkerConfig { /* private fields */ }

Available on crate feature storage only.

Allows configuring of how storages are consumed

Implementations

impl WorkerConfig

pub fn buffer_size(self, buffer_size: usize) -> Self

The number of jobs to fetch in one poll

Defaults to 1

pub fn enqueue_scheduled(self, interval: Option<(i32, Duration)>) -> Self

The rate at which jobs in the scheduled queue are pushed into the active queue

Can be set to none for sql scenarios as sql uses run_at This mainly applies for redis currently

pub fn reenqueue_orphaned(self, interval: Option<(i32, Duration)>) -> Self

The rate at which orphaned jobs are returned to the queue

If None then no garbage collection of orphaned jobs

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

The rate at which polling is occurring This may be ignored if the storage uses pubsub

Trait Implementations

impl Debug for WorkerConfig

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

Formats the value using the given formatter.

impl Default for WorkerConfig

fn default() -> Self

Returns the “default value” for a type.