Struct AsyncPool 

pub struct AsyncPool { /* private fields */ }

Thread-safe async connection pool for VoltDB.

Example

use voltdb_client_rust::{AsyncPool, AsyncPoolConfig, Opts, IpPort};

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

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

Implementations

impl AsyncPool

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

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

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

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

pub async fn with_config<T: Into<Opts>>( opts: T, config: AsyncPoolConfig, ) -> Result<AsyncPool, VoltError>

Create a new pool with full configuration.

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

Get a connection from the pool.

pub async fn shutdown(&self)

Initiate graceful shutdown.

pub fn is_shutdown(&self) -> bool

Check if pool is shut down.

pub async fn stats(&self) -> AsyncPoolStats

Get current pool statistics.

Trait Implementations

impl Debug for AsyncPool

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

Formats the value using the given formatter.