Struct RedisConnection 

pub struct RedisConnection { /* private fields */ }

Redis connection wrapper that manages connection lifecycle.

Supports both single-node and cluster connections based on configuration.

Implementations

impl RedisConnection

pub fn new(url: &str) -> Result<Self>

Create a new Redis connection from a URL.

Arguments

• url - Redis connection URL (e.g., “redis://localhost:6379”)

For cluster connections, use redis+cluster:// scheme or [from_config].

Examples

// Single node
let conn = RedisConnection::new("redis://localhost:6379")?;

// Cluster (auto-detected from scheme)
let conn = RedisConnection::new("redis+cluster://node1:7000")?;

pub fn from_config(config: ConnectionConfig) -> Result<Self>

Create a connection from a configuration.

Examples

// Single node
let config = ConnectionConfig::single("redis://localhost:6379");
let conn = RedisConnection::from_config(config)?;

// Cluster with multiple initial nodes
let config = ConnectionConfig::cluster(&[
    "redis://node1:7000",
    "redis://node2:7001",
]);
let conn = RedisConnection::from_config(config)?;

pub fn is_cluster(&self) -> bool

Check if this is a cluster connection.

pub async fn get_connection(&self) -> Result<RedisConn>

Get a unified async connection.

Returns a RedisConn that works with both single-node and cluster.

pub async fn get_async_connection(&self) -> Result<MultiplexedConnection>

Get an async multiplexed connection (single-node only).

pub async fn get_connection_manager(&self) -> Result<ConnectionManager>

Get a ConnectionManager for async operations with auto-reconnection.

ConnectionManager is cheap to clone and provides automatic reconnection on connection failures. Preferred over get_async_connection() for long-running operations.

pub fn get_sync_connection(&self) -> Result<Connection>

Get a sync connection (for simple operations, single-node only).