Struct redis::cluster::ClusterConnection [−][src]
pub struct ClusterConnection { /* fields omitted */ }
cluster
only.Expand description
This is a connection of Redis cluster.
Implementations
impl ClusterConnection
[src]
impl ClusterConnection
[src]pub fn set_auto_reconnect(&self, value: bool)
[src]
pub fn set_auto_reconnect(&self, value: bool)
[src]Set an auto reconnect attribute. Default value is true;
pub fn set_write_timeout(&self, dur: Option<Duration>) -> RedisResult<()>
[src]
pub fn set_write_timeout(&self, dur: Option<Duration>) -> RedisResult<()>
[src]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<()>
[src]
pub fn set_read_timeout(&self, dur: Option<Duration>) -> RedisResult<()>
[src]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.
pub fn check_connection(&mut self) -> bool
[src]
pub fn check_connection(&mut self) -> bool
[src]Check that all connections it has are available (PING
internally).
Trait Implementations
impl ConnectionLike for ClusterConnection
[src]
impl ConnectionLike for ClusterConnection
[src]fn supports_pipelining(&self) -> bool
[src]
fn req_command(&mut self, cmd: &Cmd) -> RedisResult<Value>
[src]
fn req_command(&mut self, cmd: &Cmd) -> RedisResult<Value>
[src]Sends a Cmd into the TCP socket and reads a single response from it.
fn req_packed_command(&mut self, cmd: &[u8]) -> RedisResult<Value>
[src]
fn req_packed_command(&mut self, cmd: &[u8]) -> RedisResult<Value>
[src]Sends an already encoded (packed) command into the TCP socket and reads the single response from it. Read more
fn req_packed_commands(
&mut self,
cmd: &[u8],
offset: usize,
count: usize
) -> RedisResult<Vec<Value>>
[src]
fn req_packed_commands(
&mut self,
cmd: &[u8],
offset: usize,
count: usize
) -> RedisResult<Vec<Value>>
[src]Sends multiple already encoded (packed) command into the TCP socket
and reads count
responses from it. This is used to implement
pipelining. Read more
fn get_db(&self) -> i64
[src]
fn get_db(&self) -> i64
[src]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. Read more
fn check_connection(&mut self) -> bool
[src]
fn check_connection(&mut self) -> bool
[src]Check that all connections it has are available (PING
internally).
Auto Trait Implementations
impl !RefUnwindSafe for ClusterConnection
impl Send for ClusterConnection
impl !Sync for ClusterConnection
impl Unpin for ClusterConnection
impl !UnwindSafe for ClusterConnection
Blanket Implementations
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]
impl<T> BorrowMut<T> for T where
T: ?Sized,
[src]pub fn borrow_mut(&mut self) -> &mut T
[src]
pub fn borrow_mut(&mut self) -> &mut T
[src]Mutably borrows from an owned value. Read more
impl<V, T> VZip<V> for T where
V: MultiLane<T>,
impl<V, T> VZip<V> for T where
V: MultiLane<T>,