Struct Postgres 

pub struct Postgres { /* private fields */ }

An open Postgres connection pool (sqlx 0.8, runtime-tokio, tls-rustls).

One pool per tenant database: ADR 0008 keeps tenants isolated at the database boundary, and the native runtime (#19) holds one adapter per tenant.

Implementations

impl Postgres

pub async fn apply_migrations( &self, module: &str, migrations: &[SqlMigration], ) -> Result<(), DbError>

Applies a module’s unapplied migrations in id order, tracked under <module>/<id> in a harness_migrations table; each migration runs in its own transaction so a failure rolls back atomically and re-running is idempotent. Mirrors SqliteDatabase::apply_migrations exactly.

Errors

DbError::Batch when the tracking DDL or a migration’s SQL fails, or when the bookkeeping insert cannot be rendered.

pub async fn apply_harness_migrations( &self, harness: &Harness, ) -> Result<(), DbError>

Applies every module’s migrations for a whole harness, in lock order: modules in harness (config) order, each set by zero-padded migration id — the order fz migrations collect pins in .harness-lock.json. For each module the postgres set applies when shipped, else the sqlite set when it passes the portable lint (select_set).

Errors

DbError::Batch when a module’s sqlite set fails the lint or any migration fails to apply.

impl Postgres

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

Opens a pool and establishes at least one connection, failing fast on an unreachable server or bad credentials.

Errors

DbError::Execute when the pool cannot connect.

pub async fn close(&self) -> Result<(), DbError>

Closes the pool: waits for in-flight queries, then closes every connection. Dropping the adapter eventually closes the pool too; close makes shutdown deterministic for the parity kit and the native runtime.

Errors

DbError::Execute when the pool cannot be closed.

Trait Implementations

impl Database for Postgres

fn batch<'life0, 'life1, 'async_trait>( &'life0 self, stmts: &'life1 [Statement], ) -> Pin<Box<dyn Future<Output = Result<(), DbError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Runs all statements in one transaction (atomic on Postgres).

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, stmt: &'life1 Statement, ) -> Pin<Box<dyn Future<Output = Result<u64, DbError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

fn query<'life0, 'life1, 'async_trait>( &'life0 self, stmt: &'life1 Statement, ) -> Pin<Box<dyn Future<Output = Result<Rows, DbError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,