Enum OptimizedPool 

pub enum OptimizedPool {
    Multiplexed(OptimizedMultiplexedPool),
    Pool(Box<LockFreeConnectionPool>),
}

Unified optimized pool abstraction

Variants

Multiplexed(OptimizedMultiplexedPool)

Optimized multiplexed connection

Pool(Box<LockFreeConnectionPool>)

Lock-free connection pool

Implementations

impl OptimizedPool

pub async fn new( config: ConnectionConfig, host: String, port: u16, ) -> RedisResult<Self>

Create a new optimized pool based on the configuration

pub async fn execute_command( &self, command: String, args: Vec<RespValue>, ) -> RedisResult<RespValue>

Execute a command through the optimized pool

pub async fn stats(&self) -> PoolStats

Get current pool statistics

pub async fn shutdown(&self)

Shutdown the pool gracefully