Struct Connection 

pub struct Connection { /* private fields */ }

A wrapped redis::aio::MultiplexedConnection that can auto-reconnect.

Implementations

impl Connection

pub async fn create( node: NodeId, options: Arc<RedisConnectOptions>, ) -> RedisResult<Self>

Create a connection; return error if failed.

pub async fn create_or_reconnect( node: NodeId, options: Arc<RedisConnectOptions>, ) -> RedisResult<Self>

Create a connection; but retry later if failed.

pub fn reconnect(&mut self)

Drop the connection and reconnect later.

pub async fn get(&mut self) -> RedisResult<&mut MultiplexedConnection>

Get a mutable connection, will wait and retry a few times until dead.

pub fn try_get(&mut self) -> RedisResult<&mut MultiplexedConnection>

Get a mutable connection, only if it is alive.

pub fn protocol(&self) -> &str

pub fn node_id(&self) -> &NodeId

Trait Implementations

impl Debug for Connection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.