Trait redis::aio::ConnectionLike

pub trait ConnectionLike {
    fn req_packed_command<'a>(
        &'a mut self, 
        cmd: &'a Cmd
    ) -> RedisFuture<'a, Value>;
    fn req_packed_commands<'a>(
        &'a mut self, 
        cmd: &'a Pipeline, 
        offset: usize, 
        count: usize
    ) -> RedisFuture<'a, Vec<Value>>;
    fn get_db(&self) -> i64;
}

This is supported on crate feature aio only.

An async abstraction over connections.

Required methods

fn req_packed_command<'a>(&'a mut self, cmd: &'a Cmd) -> RedisFuture<'a, Value>

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

fn req_packed_commands<'a>(
    &'a mut self,
    cmd: &'a Pipeline,
    offset: usize,
    count: usize
) -> RedisFuture<'a, 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.

Loading content...

Implementors

impl ConnectionLike for ConnectionManager

fn req_packed_command<'a>(&'a mut self, cmd: &'a Cmd) -> RedisFuture<'a, Value>

fn req_packed_commands<'a>(
    &'a mut self,
    cmd: &'a Pipeline,
    offset: usize,
    count: usize
) -> RedisFuture<'a, Vec<Value>>

fn get_db(&self) -> i64

impl ConnectionLike for MultiplexedConnection

fn req_packed_command<'a>(&'a mut self, cmd: &'a Cmd) -> RedisFuture<'a, Value>

fn req_packed_commands<'a>(
    &'a mut self,
    cmd: &'a Pipeline,
    offset: usize,
    count: usize
) -> RedisFuture<'a, Vec<Value>>

fn get_db(&self) -> i64

impl<C> ConnectionLike for Connection<C> where
    C: Unpin + AsyncRead + AsyncWrite + Send, 

fn req_packed_command<'a>(&'a mut self, cmd: &'a Cmd) -> RedisFuture<'a, Value>

fn req_packed_commands<'a>(
    &'a mut self,
    cmd: &'a Pipeline,
    offset: usize,
    count: usize
) -> RedisFuture<'a, Vec<Value>>

fn get_db(&self) -> i64

Loading content...