Struct FlightClientPool 

pub struct FlightClientPool { /* private fields */ }

Connection pool for managing multiple Flight clients.

Implementations

impl FlightClientPool

pub fn new(max_size: usize) -> Self

Create a new client pool.

pub async fn add_client(&mut self, address: String) -> Result<()>

Add a client to the pool.

pub fn get_client(&mut self) -> Result<&mut FlightClient>

Get a client from the pool (round-robin).

pub fn size(&self) -> usize

Get the number of clients in the pool.

pub async fn health_check_all(&mut self) -> Result<Vec<bool>>

Check health of all clients.