Struct Pool 

pub struct Pool { /* private fields */ }

Thread-safe connection pool for VoltDB.

Thread Safety

Pool is designed for high concurrency:

• Pool lock only guards metadata (microseconds)
• Each connection has its own lock for I/O
• Network I/O never blocks other threads from getting connections

Example

use voltdb_client_rust::{Pool, PoolConfig, Opts, IpPort};

let hosts = vec![IpPort::new("localhost".to_string(), 21212)];
let config = PoolConfig::new().size(5);
let pool = Pool::with_config(Opts::new(hosts), config)?;

let mut conn = pool.get_conn()?;
let table = conn.query("SELECT * FROM foo")?;

Implementations

impl Pool

pub fn new<T: Into<Opts>>(opts: T) -> Result<Pool, VoltError>

Create a new pool with default configuration (10 connections).

pub fn new_manual<T: Into<Opts>>( size: usize, opts: T, ) -> Result<Pool, VoltError>

Create a new pool with custom size (convenience method).

pub fn with_config<T: Into<Opts>>( opts: T, config: PoolConfig, ) -> Result<Pool, VoltError>

Create a new pool with full configuration.

pub fn get_conn(&self) -> Result<PooledConn<'_>, VoltError>

Get a connection from the pool.

Errors

• PoolError::PoolShutdown if pool is shutting down
• PoolError::PoolExhausted if no healthy connections (FailFast policy)
• PoolError::Timeout if wait times out (Block policy)

pub fn shutdown(&self)

Initiate graceful shutdown.

This method:

1. Stops accepting new connections
2. Closes all connections

Note: Since VoltDB connections are shared (multiple threads can use the same connection concurrently), we don’t track “active” connections. Shutdown simply prevents new checkouts and clears the connections.

pub fn is_shutdown(&self) -> bool

Check if pool is shut down.

pub fn stats(&self) -> PoolStats

Get current pool statistics.

Trait Implementations

impl Debug for Pool

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

Formats the value using the given formatter.