Struct ClusterDriver

pub struct ClusterDriver { /* private fields */ }

Available on crate features redis and redis-cluster only.

A driver implementation for the redis pub/sub backend.

Implementations

impl ClusterDriver

pub async fn new(client: &ClusterClient) -> Result<Self, RedisError>

Create a new redis driver from a redis cluster client.

Trait Implementations

impl Clone for ClusterDriver

fn clone(&self) -> ClusterDriver

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Driver for ClusterDriver

type Error = RedisError

The error type for the driver.

async fn publish(&self, chan: String, val: Vec<u8>) -> Result<(), Self::Error>

Publish a message to a channel.

async fn subscribe( &self, chan: String, size: usize, ) -> Result<MessageStream<ChanItem>, Self::Error>

Subscribe to a channel, it will return a stream of messages. The size parameter is the buffer size of the channel.

async fn unsubscribe(&self, chan: String) -> Result<(), Self::Error>

Unsubscribe from a channel.

async fn num_serv(&self, chan: &str) -> Result<u16, Self::Error>

Returns the number of socket.io servers.