Struct Config 

pub struct Config { /* private fields */ }

Configuration for the LibsqlStorage backend

Implementations

impl Config

pub fn new(queue: impl Into<String>) -> Self

Create a new config with the given queue name

pub fn queue(&self) -> &Queue

Get the queue

pub fn buffer_size(&self) -> usize

Get the buffer size

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

Set the buffer size

Panics

Panics if size is 0.

pub fn poll_interval(&self) -> Duration

Get the poll interval

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

Set the poll interval

pub fn keep_alive(&self) -> Duration

Get the keep alive interval

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

Set the keep alive interval

pub fn reenqueue_orphaned_after(&self) -> Duration

Get the duration after which orphaned tasks are re-enqueued

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

Set the duration after which orphaned tasks are re-enqueued

Trait Implementations

impl Clone for Config

fn clone(&self) -> Config

Returns a duplicate 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.