Struct RedisListPublisher 

pub struct RedisListPublisher { /* private fields */ }

Publishes onto a list with LPUSH, so right-popping consumers see FIFO order.

Obtain it from RedisBroker::list_publisher. Headers are framed around the payload; set a codec for a readable wire format (it must match the subscriber’s).

Implementations

impl RedisListPublisher

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

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

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

Sets a time-to-live on the list key, refreshed (PEXPIRE) on every publish, so an idle queue auto-expires. Off by default: without it the list lives until drained or deleted.

This is a per-key TTL on the whole list, not per-entry: Redis lists have no per-element expiry, only the key can expire. Each publish pushes the entry and re-arms the key’s TTL in one pipeline, so an actively used queue never expires and only an idle one does. A sub- millisecond ttl is clamped up to 1ms, since PEXPIRE 0 would delete the key outright.

Examples

use std::time::Duration;
use ruststream_fred::RedisBroker;

let broker = RedisBroker::connect("redis://localhost:6379").await?;
let publisher = broker.list_publisher().ttl(Duration::from_secs(300));

Trait Implementations

impl Clone for RedisListPublisher

fn clone(&self) -> RedisListPublisher

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RedisListPublisher

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

Formats the value using the given formatter.

impl Publisher for RedisListPublisher

type Error = RedisError

The error type returned by publish.

async fn publish(&self, msg: OutgoingMessage<'_>) -> Result<(), Self::Error>

Publishes a message to the broker.