Struct MultiRegionPoolManager 

pub struct MultiRegionPoolManager { /* private fields */ }

Multi-region pool manager

Implementations

impl MultiRegionPoolManager

pub fn new(max_lag_seconds: f64) -> Self

Create a new multi-region pool manager

pub async fn add_regional_pool(&self, config: RegionalPoolConfig) -> Result<()>

Add a regional pool

pub fn get_regional_pool(&self, region_code: &str) -> Result<PgPool>

Get pool for a specific region

pub fn get_closest_pool( &self, latitude: f64, longitude: f64, ) -> Result<(String, PgPool)>

Get pool for the closest region to a given location

pub fn get_primary_pool(&self) -> Result<PgPool>

Get primary pool

pub fn get_current_pool(&self) -> Result<PgPool>

Get pool for the current active region

pub fn failover_to_region(&self, region_code: &str) -> Result<()>

Switch to a different region (failover)

pub async fn measure_replication_lag( &self, source_region: &str, replica_region: &str, ) -> Result<ReplicationLag>

Measure replication lag for a replica

pub fn get_replication_lags(&self) -> HashMap<String, ReplicationLag>

Get all replication lags

pub fn are_all_replicas_healthy(&self) -> bool

Check if all replicas are healthy

pub fn get_unhealthy_replicas(&self) -> Vec<String>

Get unhealthy replicas

pub fn auto_failover(&self) -> Result<String>

Auto-failover to the best available region

pub fn list_regions(&self) -> Vec<RegionalPoolConfig>

List all regions

pub fn get_current_region(&self) -> Option<String>

Get current region