Struct Database 

pub struct Database { /* private fields */ }

Database connection wrapper with health-aware replica routing and workload isolation.

Implementations

impl Database

pub async fn from_config(config: &DatabaseConfig) -> Result<Self>

Create a new database connection from configuration.

pub async fn from_config_with_service( config: &DatabaseConfig, service_name: &str, ) -> Result<Self>

Create a new database connection with a service name for tracing.

The service name is set as PostgreSQL’s application_name, visible in pg_stat_activity for correlating queries to the originating service.

pub fn primary(&self) -> &PgPool

Get the primary pool for writes.

pub fn read_pool(&self) -> &PgPool

Get a pool for reads. Skips unhealthy replicas, falls back to primary.

pub fn jobs_pool(&self) -> &PgPool

Pool for background jobs, cron, daemons, and workflows. Falls back to primary if no isolated pool is configured.

pub fn observability_pool(&self) -> &PgPool

Pool for observability writes (metrics, slow query logs). Falls back to primary if no isolated pool is configured.

pub fn analytics_pool(&self) -> &PgPool

Pool for long-running analytics queries. Falls back to primary if no isolated pool is configured.

pub fn start_health_monitor(&self) -> Option<JoinHandle<()>>

Start background health monitoring for replicas. Returns None if no replicas configured.

pub async fn health_check(&self) -> Result<()>

Check database connectivity.

pub async fn close(&self)

Close all connections gracefully.

Trait Implementations

impl Clone for Database

fn clone(&self) -> Database

Returns a duplicate of the value.

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

Performs copy-assignment from source.