Struct ConnectionPool 

pub struct ConnectionPool { /* private fields */ }

Connection pool for managing AimDB connections

Implementations

impl ConnectionPool

pub fn new() -> Self

Create a new connection pool

pub async fn get_connection( &self, socket_path: &str, ) -> Result<AimxClient, ClientError>

Get or create a connection to an AimDB instance

Note: Since AimxClient doesn’t implement Clone, we create a fresh connection each time. The pool tracks connection metadata for monitoring and future optimization (e.g., persistent connections via Arc<Mutex> if AimxClient becomes Sync).

pub async fn invalidate_connection(&self, socket_path: &str)

Remove a connection from the pool (called when operations fail)

pub async fn get_drain_client( &self, socket_path: &str, ) -> Result<Arc<Mutex<AimxClient>>, ClientError>

Get or create a persistent drain client for a socket path.

Drain clients are kept alive across calls so the server-side drain reader accumulates values between invocations. The first drain call on a new connection is a cold start (returns empty); subsequent calls return all values accumulated since the previous drain.

pub async fn invalidate_drain_client(&self, socket_path: &str)

Invalidate (remove) a persistent drain client, e.g. after connection error

pub async fn clear(&self)

Clear all connections in the pool

pub async fn connection_count(&self) -> usize

Get the number of tracked connections

Trait Implementations

impl Clone for ConnectionPool

fn clone(&self) -> ConnectionPool

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ConnectionPool

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

Formats the value using the given formatter.

impl Default for ConnectionPool

fn default() -> Self

Returns the “default value” for a type.