Struct PoolWithSchema 

pub struct PoolWithSchema { /* private fields */ }

Database pool with per-pool schema readiness tracking.

Wraps DbPool and adds an AtomicBool flag to track schema initialization per pool instance. This eliminates the issue of global state interfering when multiple pools point to different databases.

Implementations

impl PoolWithSchema

pub fn new(pool: Arc<DbPool>) -> Self

Creates a new pool with schema tracking.

pub fn with_postgres_migration_timeout( pool: Arc<DbPool>, postgres_migration_timeout: Duration, ) -> Self

Creates a new pool with schema tracking and a PostgreSQL migration timeout.

pub fn pool(&self) -> &Arc<DbPool>

Returns a reference to the underlying database pool.

pub async fn ensure_schema_ready(&self) -> Result<(), Error>

Ensures database schema is ready by running pending migrations.

Checks if migrations have already been applied via one of:

1. Per-pool flag (schema_ready)
2. AGENTIC_API_SCHEMA_READY environment variable

If none of the above, runs all pending migrations from the migrations/ directory. Supervisor-managed PostgreSQL schemas still verify required compatibility upgrades.

Errors

Returns a sqlx::Error if migrations fail.