Struct redis::cluster::ClusterConnection

pub struct ClusterConnection<C = Connection> { /* private fields */ }

Available on crate feature cluster only.

This represents a Redis Cluster connection. It stores the underlying connections maintained for each node in the cluster, as well as common parameters for connecting to nodes and executing commands.

Implementations

impl<C> ClusterConnection<C>where C: ConnectionLike + Connect,

pub fn set_auto_reconnect(&self, value: bool)

Set an auto reconnect attribute. Default value is true;

pub fn set_write_timeout(&self, dur: Option<Duration>) -> RedisResult<()>

Sets the write timeout for the connection.

If the provided value is None, then send_packed_command call will block indefinitely. It is an error to pass the zero Duration to this method.

pub fn set_read_timeout(&self, dur: Option<Duration>) -> RedisResult<()>

Sets the read timeout for the connection.

If the provided value is None, then recv_response call will block indefinitely. It is an error to pass the zero Duration to this method.

Trait Implementations

impl<C: Connect + ConnectionLike> ConnectionLike for ClusterConnection<C>

fn req_command(&mut self, cmd: &Cmd) -> RedisResult<Value>

Sends a Cmd into the TCP socket and reads a single response from it.

fn req_packed_command(&mut self, cmd: &[u8]) -> RedisResult<Value>

Sends an already encoded (packed) command into the TCP socket and reads the single response from it.

fn req_packed_commands( &mut self, cmd: &[u8], offset: usize, count: usize ) -> RedisResult<Vec<Value>>

Sends multiple already encoded (packed) command into the TCP socket and reads count responses from it. This is used to implement pipelining.

fn get_db(&self) -> i64

Returns the database this connection is bound to. Note that this information might be unreliable because it’s initially cached and also might be incorrect if the connection like object is not actually connected.

fn is_open(&self) -> bool

Returns the connection status.

fn check_connection(&mut self) -> bool

Check that all connections it has are available (PING internally).