Struct RedisListPublish 

pub struct RedisListPublish { /* private fields */ }

The declaration half of the list publisher: envelope codec and key TTL, no connection.

Constructible anywhere, it pairs into a RedisListPublisher against a ConnectedRedisBroker.

Examples

use std::time::Duration;
use ruststream::codec::JsonCodec;
use ruststream_fred::RedisListPublish;

let publish = RedisListPublish::new()
    .codec(JsonCodec)
    .ttl(Duration::from_secs(300));

Implementations

impl RedisListPublish

pub fn new() -> Self

A policy with the default binary framing and no key TTL. Equivalent to Self::default.

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.

Trait Implementations

impl Clone for RedisListPublish

fn clone(&self) -> RedisListPublish

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RedisListPublish

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

Formats the value using the given formatter.

impl Default for RedisListPublish

fn default() -> RedisListPublish

Returns the “default value” for a type.

impl PublishPolicy<ConnectedRedisBroker> for RedisListPublish

type Live = RedisListPublisher

The live form this policy pairs into: a Publisher for a leaf policy, or the live wiring form for a combinator stack (a typed publisher over a policy pairs into the same typed publisher over the live leaf).

async fn pair( self, connected: &ConnectedRedisBroker, ) -> Result<Self::Live, PairError>

Pairs the policy with a connected broker, producing the live publisher.