Struct ArclyDbPool 

pub struct ArclyDbPool { /* private fields */ }

Primary + replicas for one logical database. Build at boot (plugin on_init), register into DataSourceRegistry<ArclyDbPool>, freeze.

Implementations

impl ArclyDbPool

pub fn new(name: &'static str, primary: DbDriver) -> Self

pub fn with_replica(self, replica: DbDriver) -> Self

Add a read replica (boot-time only — consumes self).

impl ArclyDbPool

pub async fn begin(&self) -> Result<ArclyTransaction, DataError>

Open a transaction on the primary driver of this pool.

Trait Implementations

impl DataSource for ArclyDbPool

type Conn = OwnedDbConn

fn acquire( &self, intent: AccessIntent, ) -> BoxFuture<'_, Result<Self::Conn, DataError>>

fn name(&self) -> &'static str

Logical name (matches TenantConfig::datasource). For logs/metrics.