Trait reool::ConnectionLike[][src]

pub trait ConnectionLike {
    pub fn req_packed_command(
        &'a mut self,
        cmd: &'a Cmd
    ) -> Pin<Box<dyn Future<Output = Result<Value, RedisError>> + 'a + Send, Global>>;
pub fn req_packed_commands(
        &'a mut self,
        cmd: &'a Pipeline,
        offset: usize,
        count: usize
    ) -> Pin<Box<dyn Future<Output = Result<Vec<Value, Global>, RedisError>> + 'a + Send, Global>>;
pub fn get_db(&self) -> i64; }

An async abstraction over connections.

Required methods

pub fn req_packed_command(
    &'a mut self,
    cmd: &'a Cmd
) -> Pin<Box<dyn Future<Output = Result<Value, RedisError>> + 'a + Send, Global>>
[src]

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

pub fn req_packed_commands(
    &'a mut self,
    cmd: &'a Pipeline,
    offset: usize,
    count: usize
) -> Pin<Box<dyn Future<Output = Result<Vec<Value, Global>, RedisError>> + 'a + Send, Global>>
[src]

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

pub 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.

Loading content...

Implementations on Foreign Types

impl<C> ConnectionLike for Connection<C> where
    C: Unpin + AsyncRead + AsyncWrite + Send
[src]

impl ConnectionLike for MultiplexedConnection[src]

Loading content...

Implementors

impl ConnectionLike for ConnectionFlavour[src]

impl ConnectionLike for RedisPool[src]

impl<T: Poolable> ConnectionLike for PoolConnection<T> where
    T: ConnectionLike
[src]

Loading content...