Struct RiConnectionPool 

pub struct RiConnectionPool {
    pub active_connections: usize,
    pub failed_connections: usize,
    pub total_errors: usize,
    /* private fields */
}

Connection pool for managing device connections with lifecycle and health monitoring

Fields

active_connections: usize

Number of active connections

failed_connections: usize

Number of failed connections

total_errors: usize

Total number of errors

Implementations

impl RiConnectionPool

pub fn new( max_connections: usize, connection_timeout: Duration, health_check_interval: Duration, ) -> Self

Creates a new connection pool

pub fn add_connection(&mut self, device_id: String, address: String)

Adds a new connection to the pool

pub fn remove_connection(&mut self, connection_id: &str) -> bool

Removes a connection from the pool

pub fn get_connection(&self, connection_id: &str) -> Option<&RiConnectionInfo>

Gets connection information

pub fn update_activity(&mut self, connection_id: &str) -> bool

Updates connection activity

pub fn update_health_metrics( &mut self, connection_id: &str, success: bool, response_time_ms: f64, ) -> bool

Updates connection health metrics

pub fn perform_health_check(&mut self)

Performs health check on all connections

pub fn active_connections(&self) -> usize

Gets the number of active connections

pub fn idle_connections(&self) -> usize

Gets the number of idle connections

pub fn unhealthy_connections(&self) -> usize

Gets the number of unhealthy connections

pub fn get_statistics(&self) -> RiConnectionPoolStatistics

Gets overall connection pool statistics

Trait Implementations

impl Clone for RiConnectionPool

fn clone(&self) -> RiConnectionPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RiConnectionPool

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

Formats the value using the given formatter.