Struct RedisList 

pub struct RedisList { /* private fields */ }

Describes one list subscription against crate::RedisBroker.

Examples

use std::time::Duration;
use ruststream_fred::RedisList;

let simple = RedisList::new("jobs");
let reliable = RedisList::new("jobs").reliable().block(Duration::from_secs(2));

Implementations

impl RedisList

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

A simple (at-most-once) BRPOP work-queue consumer on key.

pub const fn reliable(self) -> Self

Switches to reliable (at-least-once) mode: entries move to a processing list and are removed on ack.

pub fn processing(self, key: impl Into<String>) -> Self

Sets the processing-list key used in reliable mode. Defaults to <key>.processing.

pub const fn block(self, block: Duration) -> Self

How long one blocking pop waits before looping. Defaults to 5 seconds.

pub fn codec(self, codec: impl Codec + 'static) -> Self

Decodes the header/payload envelope with codec (must match the publisher). Without it the default lossless binary framing is used.

pub fn key(&self) -> &str

The list key this subscription consumes.

Trait Implementations

impl Clone for RedisList

fn clone(&self) -> RedisList

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RedisList

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

Formats the value using the given formatter.

impl SubscriptionSource<RedisBroker> for RedisList

type Subscriber = RedisListSubscriber

The subscriber type this source opens.

fn name(&self) -> &str

The name (subject / channel) this subscription binds to.

async fn subscribe( self, broker: &RedisBroker, ) -> Result<Self::Subscriber, RedisError>

Opens the subscription against broker. Called once, after Broker::connect.