Struct QueueConfig 

pub struct QueueConfig {
    pub redis_url: String,
    pub queue_name: String,
    pub key_prefix: String,
    pub max_size: usize,
    pub retention_time: Duration,
}

Queue configuration.

Fields

redis_url: String

Redis connection URL

queue_name: String

Queue name

key_prefix: String

Key prefix for Redis keys

max_size: usize

Maximum queue size (0 = unlimited)

retention_time: Duration

Job retention time for completed jobs

Implementations

impl QueueConfig

pub fn new(redis_url: impl Into<String>, queue_name: impl Into<String>) -> Self

Create a new queue configuration.

pub fn with_key_prefix(self, prefix: impl Into<String>) -> Self

Set the key prefix.

pub fn with_max_size(self, max_size: usize) -> Self

Set the maximum queue size.

pub fn with_retention_time(self, retention_time: Duration) -> Self

Set the retention time for completed jobs.

Trait Implementations

impl Clone for QueueConfig

fn clone(&self) -> QueueConfig

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QueueConfig

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

Formats the value using the given formatter.