pub struct LockFreeConnectionPool { /* private fields */ }Expand description
Lock-free connection pool with atomic operations
Implementations§
Source§impl LockFreeConnectionPool
impl LockFreeConnectionPool
Sourcepub async fn new(
config: ConnectionConfig,
host: String,
port: u16,
max_size: usize,
) -> RedisResult<Self>
pub async fn new( config: ConnectionConfig, host: String, port: u16, max_size: usize, ) -> RedisResult<Self>
Create a new lock-free connection pool
Sourcepub async fn execute_command(
&self,
command: String,
args: Vec<RespValue>,
) -> RedisResult<RespValue>
pub async fn execute_command( &self, command: String, args: Vec<RespValue>, ) -> RedisResult<RespValue>
Execute a command using a connection from the pool
Auto Trait Implementations§
impl Freeze for LockFreeConnectionPool
impl !RefUnwindSafe for LockFreeConnectionPool
impl Send for LockFreeConnectionPool
impl Sync for LockFreeConnectionPool
impl Unpin for LockFreeConnectionPool
impl !UnwindSafe for LockFreeConnectionPool
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more