Struct Config

pub struct Config { /* private fields */ }

Config for a RedisStorage

Implementations

impl Config

pub fn get_poll_interval(&self) -> &Duration

Get the interval of polling

pub fn get_buffer_size(&self) -> usize

Get the number of jobs to fetch

pub fn get_keep_alive(&self) -> &Duration

get the keep live rate

pub fn get_enqueue_scheduled(&self) -> &Duration

get the enqueued setting

pub fn get_namespace(&self) -> &String

get the namespace

pub fn set_poll_interval(self, poll_interval: Duration) -> Self

get the poll interval

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

set the buffer setting

pub fn set_keep_alive(self, keep_alive: Duration) -> Self

set the keep-alive setting

pub fn set_enqueue_scheduled(self, enqueue_scheduled: Duration) -> Self

get the enqueued setting

pub fn set_namespace(self, namespace: &str) -> Self

set the namespace for the Storage

pub fn active_jobs_list(&self) -> String

Returns the Redis key for the list of pending jobs associated with the queue. The key is dynamically generated using the namespace of the queue.

Returns

A String representing the Redis key for the pending jobs list.

pub fn consumers_set(&self) -> String

Returns the Redis key for the set of consumers associated with the queue. The key is dynamically generated using the namespace of the queue.

Returns

A String representing the Redis key for the consumers set.

pub fn dead_jobs_set(&self) -> String

Returns the Redis key for the set of dead jobs associated with the queue. The key is dynamically generated using the namespace of the queue.

Returns

A String representing the Redis key for the dead jobs set.

pub fn done_jobs_set(&self) -> String

Returns the Redis key for the set of done jobs associated with the queue. The key is dynamically generated using the namespace of the queue.

Returns

A String representing the Redis key for the done jobs set.

pub fn failed_jobs_set(&self) -> String

Returns the Redis key for the set of failed jobs associated with the queue. The key is dynamically generated using the namespace of the queue.

Returns

A String representing the Redis key for the failed jobs set.

pub fn inflight_jobs_set(&self) -> String

Returns the Redis key for the set of inflight jobs associated with the queue. The key is dynamically generated using the namespace of the queue.

Returns

A String representing the Redis key for the inflight jobs set.

pub fn job_data_hash(&self) -> String

Returns the Redis key for the hash storing job data associated with the queue. The key is dynamically generated using the namespace of the queue.

Returns

A String representing the Redis key for the job data hash.

pub fn scheduled_jobs_set(&self) -> String

Returns the Redis key for the set of scheduled jobs associated with the queue. The key is dynamically generated using the namespace of the queue.

Returns

A String representing the Redis key for the scheduled jobs set.

pub fn signal_list(&self) -> String

Returns the Redis key for the list of signals associated with the queue. The key is dynamically generated using the namespace of the queue.

Returns

A String representing the Redis key for the signal list.

pub fn reenqueue_orphaned_after(&self) -> Duration

Gets the reenqueue_orphaned_after duration.

pub fn reenqueue_orphaned_after_mut(&mut self) -> &mut Duration

Gets a mutable reference to the reenqueue_orphaned_after.

pub fn set_reenqueue_orphaned_after(self, after: Duration) -> Self

Occasionally some workers die, or abandon jobs because of panics. This is the time a task takes before its back to the queue

Defaults to 5 minutes

Trait Implementations

impl Clone for Config

fn clone(&self) -> Config

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Config

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

Formats the value using the given formatter.

impl Default for Config

fn default() -> Self

Returns the “default value” for a type.