[−][src]Trait reool::ConnectionLike
An async abstraction over connections.
Required methods
fn req_packed_command(
self,
cmd: Vec<u8>
) -> Box<dyn Future<Error = RedisError, Item = (Self, Value)> + 'static + Send>
self,
cmd: Vec<u8>
) -> Box<dyn Future<Error = RedisError, Item = (Self, Value)> + 'static + Send>
Sends an already encoded (packed) command into the TCP socket and reads the single response from it.
fn req_packed_commands(
self,
cmd: Vec<u8>,
offset: usize,
count: usize
) -> Box<dyn Future<Error = RedisError, Item = (Self, Vec<Value>)> + 'static + Send>
self,
cmd: Vec<u8>,
offset: usize,
count: usize
) -> Box<dyn Future<Error = RedisError, Item = (Self, Vec<Value>)> + 'static + Send>
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.
Implementations on Foreign Types
impl ConnectionLike for SharedConnection
[src]
fn req_packed_command(
self,
cmd: Vec<u8>
) -> Box<dyn Future<Error = RedisError, Item = (SharedConnection, Value)> + 'static + Send>
[src]
self,
cmd: Vec<u8>
) -> Box<dyn Future<Error = RedisError, Item = (SharedConnection, Value)> + 'static + Send>
fn req_packed_commands(
self,
cmd: Vec<u8>,
offset: usize,
count: usize
) -> Box<dyn Future<Error = RedisError, Item = (SharedConnection, Vec<Value>)> + 'static + Send>
[src]
self,
cmd: Vec<u8>,
offset: usize,
count: usize
) -> Box<dyn Future<Error = RedisError, Item = (SharedConnection, Vec<Value>)> + 'static + Send>
fn get_db(&self) -> i64
[src]
impl ConnectionLike for Connection
[src]
fn req_packed_command(
self,
cmd: Vec<u8>
) -> Box<dyn Future<Error = RedisError, Item = (Connection, Value)> + 'static + Send>
[src]
self,
cmd: Vec<u8>
) -> Box<dyn Future<Error = RedisError, Item = (Connection, Value)> + 'static + Send>
fn req_packed_commands(
self,
cmd: Vec<u8>,
offset: usize,
count: usize
) -> Box<dyn Future<Error = RedisError, Item = (Connection, Vec<Value>)> + 'static + Send>
[src]
self,
cmd: Vec<u8>,
offset: usize,
count: usize
) -> Box<dyn Future<Error = RedisError, Item = (Connection, Vec<Value>)> + 'static + Send>
fn get_db(&self) -> i64
[src]
Implementors
impl ConnectionLike for ConnectionFlavour
[src]
fn req_packed_command(self, cmd: Vec<u8>) -> RedisFuture<(Self, Value)>
[src]
fn req_packed_commands(
self,
cmd: Vec<u8>,
offset: usize,
count: usize
) -> RedisFuture<(Self, Vec<Value>)>
[src]
self,
cmd: Vec<u8>,
offset: usize,
count: usize
) -> RedisFuture<(Self, Vec<Value>)>
fn get_db(&self) -> i64
[src]
impl<T: Poolable> ConnectionLike for PoolConnection<T> where
T: ConnectionLike,
[src]
T: ConnectionLike,