Struct PostgresClient 

pub struct PostgresClient { /* private fields */ }

A PostgreSQL client wrapping a PgPool.

Holds a connection pool that is shared across all operations created from this client. The pool is created once and reused for the lifetime of the client.

Examples

use ironflow_ops_postgres::PostgresClient;

let client = PostgresClient::connect("postgres://localhost/mydb").await?;
let pool = client.pool();

Implementations

impl PostgresClient

pub async fn connect(url: &str) -> Result<Self, OperationError>

Connect to a PostgreSQL database using the given connection URL.

Errors

Returns OperationError::External if the connection pool cannot be created (invalid URL, unreachable server, authentication failure).

Examples

use ironflow_ops_postgres::PostgresClient;

let client = PostgresClient::connect("postgres://localhost/mydb").await?;

pub fn from_pool(pool: PgPool) -> Self

Create a client from an existing PgPool.

Examples

use ironflow_ops_postgres::PostgresClient;
use sqlx::PgPool;

let pool = PgPool::connect("postgres://localhost/mydb").await?;
let client = PostgresClient::from_pool(pool);

pub async fn from_context( ctx: &OperationContext, ) -> Result<Self, OperationError>

Create a client by reading postgres_url from the secret store.

Errors

Returns OperationError::Secret if the secret store fails, or OperationError::External if the secret is missing or the connection cannot be established.

Examples

use ironflow_ops_postgres::PostgresClient;
use ironflow_core::operation::{OperationContext, NoopSecretResolver};
use std::sync::Arc;

let ctx = OperationContext::new(Arc::new(NoopSecretResolver));
let client = PostgresClient::from_context(&ctx).await?;

pub fn pool(&self) -> &PgPool

Returns a reference to the underlying connection pool.

Trait Implementations

impl Debug for PostgresClient

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

Formats the value using the given formatter.