Struct RedisCluster 

pub struct RedisCluster { /* private fields */ }

A set of connections maintained to a Redis Cluster with key cache.

Implementations

impl RedisCluster

pub fn new( cluster: StreamerUri, options: Arc<RedisConnectOptions>, ) -> RedisResult<Self>

Nothing happens until you call connect

pub fn protocol(&self) -> Option<&str>

pub async fn reconnect_all(&mut self) -> RedisResult<()>

Will drop all existing connections. This method returns OK only if it can connect to all nodes.

pub fn reconnect(&mut self, node: &NodeId) -> RedisResult<()>

An error has occured on the connection. Attempt to reconnect later.

pub fn node_for(&self, key: &str) -> &NodeId

Get the cached node for this key. There is no guarantee that the key assignment is right.

pub fn moved(&mut self, key: &str, node: NodeId)

Indicate that the particular key has been moved to a different node in the cluster.

pub fn get_any(&mut self) -> RedisResult<(&NodeId, &mut MultiplexedConnection)>

Get any available connection to the cluster

pub async fn get( &mut self, node: &NodeId, ) -> RedisResult<&mut MultiplexedConnection>

Get a connection to the specific node, will wait and retry a few times until dead.

pub async fn get_connection_for( &mut self, key: &str, ) -> RedisResult<(&NodeId, &mut MultiplexedConnection)>

Get a connection that is assigned with the specific key, will wait and retry a few times until dead. There is no guarantee that the key assignment is right.

Trait Implementations

impl Debug for RedisCluster

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

Formats the value using the given formatter.