Struct Config

pub struct Config { /* private fields */ }

Config for sql storages

Implementations

impl Config

pub fn new(namespace: &str) -> Self

Create a new config with a jobs namespace

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

Interval between database poll queries

Defaults to 100ms

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

Interval between worker keep-alive database updates

Defaults to 30s

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

Buffer size to use when querying for jobs

Defaults to 10

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

Set the namespace to consume and push jobs to

Defaults to “apalis::sql”

pub fn keep_alive(&self) -> &Duration

Gets a reference to the keep_alive duration.

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

Gets a mutable reference to the keep_alive duration.

pub fn buffer_size(&self) -> usize

Gets the buffer size.

pub fn poll_interval(&self) -> &Duration

Gets a reference to the poll_interval duration.

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

Gets a mutable reference to the poll_interval duration.

pub fn namespace(&self) -> &String

Gets a reference to the namespace.

pub fn namespace_mut(&mut self) -> &mut String

Gets a mutable reference to the namespace.

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.