Struct QueueEventsOptions 

pub struct QueueEventsOptions {
    pub connection: RedisConnectionOptions,
    pub prefix: String,
    pub blocking_timeout: u64,
    pub last_event_id: Option<String>,
    pub autorun: bool,
}

Options for creating a QueueEvents listener.

Fields

connection: RedisConnectionOptions

Redis connection configuration.

prefix: String

Key prefix for all queue keys.

blocking_timeout: u64

Maximum time in milliseconds to block on each XREAD before looping.

Smaller values make QueueEvents::close more responsive at the cost of extra round trips; defaults to 5000.

last_event_id: Option<String>

The stream id to start reading from.

When None, only events produced after the listener starts are delivered (Redis $). Provide Some("0") to read the full history.

autorun: bool

Whether to start consuming events automatically on creation.

Trait Implementations

impl Clone for QueueEventsOptions

fn clone(&self) -> QueueEventsOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for QueueEventsOptions

fn default() -> Self

Returns the “default value” for a type.