Struct RedisPubSubPublish 

pub struct RedisPubSubPublish { /* private fields */ }

The declaration half of the Pub/Sub publisher: delivery mode and envelope codec, no connection.

Constructible anywhere (in a router definition, in configuration), it pairs into a RedisPubSubPublisher against a ConnectedRedisBroker. The publish mode must match how subscribers subscribed: a sharded publish only reaches sharded subscribers.

Examples

use ruststream_fred::{PubSubMode, RedisPubSubPublish};

let classic = RedisPubSubPublish::default();
let sharded = RedisPubSubPublish::new().mode(PubSubMode::Sharded);

Implementations

impl RedisPubSubPublish

pub fn new() -> Self

A classic-mode policy with the default binary framing. Equivalent to Self::default.

pub const fn mode(self, mode: PubSubMode) -> Self

Sets the publish mode. Defaults to PubSubMode::Classic.

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.

Trait Implementations

impl Clone for RedisPubSubPublish

fn clone(&self) -> RedisPubSubPublish

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RedisPubSubPublish

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

Formats the value using the given formatter.

impl Default for RedisPubSubPublish

fn default() -> RedisPubSubPublish

Returns the “default value” for a type.

impl PublishPolicy<ConnectedRedisBroker> for RedisPubSubPublish

type Live = RedisPubSubPublisher

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.