Enum DelayedRetry 

#[non_exhaustive]
pub enum DelayedRetry {
    DurableZset {
        key: String,
        ttl: Option<Duration>,
    },
}

How a subscription should handle retry_after / nack_after delays.

Passed to RedisStream::delayed_retry. There is no default that enables it: a delay queue costs extra Redis keys, memory, and the polling sweeper, so a user opts in and names the ZSET key explicitly (the key has no sane default).

Examples

use std::time::Duration;
use ruststream_fred::{DelayedRetry, RedisStream};

let sub = RedisStream::new("orders").group("workers").delayed_retry(
    DelayedRetry::DurableZset { key: "orders.delayed".to_owned(), ttl: None },
);

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

DurableZset

Schedule delayed redeliveries in the named ZSET.

key is the ZSET delay-queue key (required, no default). ttl, when set, PEXPIREs the key on every write so an abandoned queue cleans itself up; it must exceed the longest scheduled retry_after delay, or pending entries are dropped before they fire.

Fields

key: String

The ZSET delay-queue key.

ttl: Option<Duration>

Optional auto-cleanup TTL on the ZSET key. Must exceed the longest scheduled delay.

Trait Implementations

impl Clone for DelayedRetry

fn clone(&self) -> DelayedRetry

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for DelayedRetry

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

Formats the value using the given formatter.