Struct PgPool 

pub struct PgPool { /* private fields */ }

PostgreSQL connection pool for distributed coordination

Provides connection pooling for PostgreSQL operations. Connections are reused across operations for optimal performance.

Implementations

impl PgPool

pub async fn from_config(config: &Config) -> Result<Self, PgError>

Create a new PostgreSQL connection pool from WarpDrive config

Arguments

• config - WarpDrive configuration with database_url

Errors

Returns error if:

• No database_url configured
• Invalid connection string
• Cannot connect to database

Example

let config = Config::from_env()?;
let pool = PgPool::from_config(&config).await?;

pub async fn from_url(url: &str) -> Result<Self, PgError>

Create a new PostgreSQL connection pool from a connection URL

Arguments

• url - PostgreSQL connection string (postgres://…)

Errors

Returns error if connection string is invalid or connection fails

pub async fn get(&self) -> Result<Object, PgError>

Get a client from the pool

Errors

Returns error if no connections are available or connection is broken

pub async fn execute( &self, query: &str, params: &[&(dyn ToSql + Sync)], ) -> Result<u64, PgError>

Execute a raw SQL query (for testing/debugging)

Errors

Returns error if query fails

Trait Implementations

impl Clone for PgPool

fn clone(&self) -> PgPool

Returns a duplicate of the value.

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

Performs copy-assignment from source.