Struct Config 

pub struct Config<Codec = JsonCodec<Vec<u8>>> { /* private fields */ }

Configuration for apalis-pgmq

Implementations

impl<Codec> Config<Codec>

pub fn queue(&self) -> &Queue

Gets the queue name

pub fn with_queue<S: AsRef<str>>(self, queue: S) -> Self

Sets the queue name (builder style)

pub fn poll_strategy(&self) -> &MultiStrategy

Gets the polling strategy

pub fn with_poll_strategy(self, strategy: MultiStrategy) -> Self

Sets the polling strategy (builder style)

pub fn buffer_size(&self) -> usize

Gets the buffer size

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

Sets the buffer size (builder style)

pub fn visibility_timeout(&self) -> Duration

Gets the visibility timeout

pub fn with_visibility_timeout(self, timeout: Duration) -> Self

Sets the visibility timeout (builder style)

pub fn with_codec<C>(self) -> Config<C>

Specify your own codec

Trait Implementations

impl<C> Clone for Config<C>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Codec: Debug> Debug for Config<Codec>

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

Formats the value using the given formatter.

impl Default for Config<JsonCodec<Vec<u8>>>

fn default() -> Self

Returns the “default value” for a type.