agentics-persistence 0.3.0

Database persistence layer for the Agentics challenge platform.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26

//! Database pool creation and health checks.

use secrecy::ExposeSecret;
use sqlx::PgPool;

use agentics_config::Config;
use agentics_error::Result;

/// Create a Postgres connection pool from application configuration.
pub async fn create_pool(config: &Config, max_connections: u32) -> Result<PgPool> {
    let pool = sqlx::postgres::PgPoolOptions::new()
        .max_connections(max_connections)
        .connect(config.database.url.expose_secret())
        .await?;
    Ok(pool)
}

/// Check database connectivity and return the server clock.
pub async fn check_database(pool: &PgPool) -> Result<agentics_domain::models::DatabaseHealth> {
    let row: (String,) = sqlx::query_as("SELECT NOW()::text").fetch_one(pool).await?;

    Ok(agentics_domain::models::DatabaseHealth {
        connected: true,
        current_time: row.0,
    })
}