Struct RedisPubSubPublisher 

pub struct RedisPubSubPublisher { /* private fields */ }

Publishes Pub/Sub messages with PUBLISH (classic) or SPUBLISH (sharded): a RedisPubSubPublish policy paired with a connection.

Obtain it from ConnectedRedisBroker::pubsub_publisher, or by pairing the policy. Like every publisher here it may outlive the connection, so publishing after shutdown reports RedisError::ShutDown.

Trait Implementations

impl Clone for RedisPubSubPublisher

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RedisPubSubPublisher

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

Formats the value using the given formatter.

impl Publisher for RedisPubSubPublisher

type Payload = Lend

The payload is read into an envelope of this crate’s own before it reaches the client, so there is nothing to keep: the publish is lent the bytes where they already are.

type Options = RedisPublishOptions

PUBLISH and SPUBLISH take a channel and a payload and nothing else, and which of the two is issued is the publisher’s mode, fixed by the policy, because a sharded publish only reaches sharded subscribers. What a call site still says is the partition key, framed into the payload with the message’s other headers.

type Error = RedisError

The error type returned by publish.

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

Publishes a message to the broker, with the per-message settings the call site adjusted.

fn base_headers(&self) -> Option<&HeaderMap>

The headers this publisher contributes to every message it sends, underneath whatever the message itself names.