Trait reool::ConnectionLike [−][src]
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]
&'a mut self,
cmd: &'a Cmd
) -> Pin<Box<dyn Future<Output = Result<Value, RedisError>> + 'a + Send, Global>>
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]
&'a mut self,
cmd: &'a Pipeline,
offset: usize,
count: usize
) -> Pin<Box<dyn Future<Output = Result<Vec<Value, Global>, RedisError>> + 'a + Send, Global>>
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.
Implementations on Foreign Types
impl<C> ConnectionLike for Connection<C> where
C: Unpin + AsyncRead + AsyncWrite + Send,
[src]
C: Unpin + AsyncRead + AsyncWrite + Send,
pub fn req_packed_command(
&'a mut self,
cmd: &'a Cmd
) -> Pin<Box<dyn Future<Output = Result<Value, RedisError>> + 'a + Send, Global>>
[src]
&'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>>
[src]
&'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
[src]
impl ConnectionLike for MultiplexedConnection
[src]
pub fn req_packed_command(
&'a mut self,
cmd: &'a Cmd
) -> Pin<Box<dyn Future<Output = Result<Value, RedisError>> + 'a + Send, Global>>
[src]
&'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>>
[src]
&'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
[src]
Implementors
impl ConnectionLike for ConnectionFlavour
[src]
fn req_packed_command<'a>(&'a mut self, cmd: &'a Cmd) -> RedisFuture<'a, Value>
[src]
fn req_packed_commands<'a>(
&'a mut self,
pipeline: &'a Pipeline,
offset: usize,
count: usize
) -> RedisFuture<'a, Vec<Value>>
[src]
&'a mut self,
pipeline: &'a Pipeline,
offset: usize,
count: usize
) -> RedisFuture<'a, Vec<Value>>
fn get_db(&self) -> i64
[src]
impl ConnectionLike for RedisPool
[src]
fn req_packed_command<'a>(&'a mut self, cmd: &'a Cmd) -> RedisFuture<'a, Value>
[src]
fn req_packed_commands<'a>(
&'a mut self,
cmd: &'a Pipeline,
offset: usize,
count: usize
) -> RedisFuture<'a, Vec<Value>>
[src]
&'a mut self,
cmd: &'a Pipeline,
offset: usize,
count: usize
) -> RedisFuture<'a, Vec<Value>>
fn get_db(&self) -> i64
[src]
impl<T: Poolable> ConnectionLike for PoolConnection<T> where
T: ConnectionLike,
[src]
T: ConnectionLike,
fn req_packed_command<'a>(&'a mut self, cmd: &'a Cmd) -> RedisFuture<'a, Value>
[src]
fn req_packed_commands<'a>(
&'a mut self,
pipeline: &'a Pipeline,
offset: usize,
count: usize
) -> RedisFuture<'a, Vec<Value>>
[src]
&'a mut self,
pipeline: &'a Pipeline,
offset: usize,
count: usize
) -> RedisFuture<'a, Vec<Value>>