Struct DataSourceRegistry 

pub struct DataSourceRegistry<D: DataSource> { /* private fields */ }

Frozen tenant→datasource map. Built once at boot, provided via DI, read lock-free on every request.

Implementations

impl<D: DataSource> DataSourceRegistry<D>

pub fn new(default: D) -> Self

pub fn with(self, name: &'static str, ds: D) -> Self

Register a named datasource (boot-time only — consumes self).

pub fn for_tenant(&self, tenant: Option<&TenantConfig>) -> &D

The datasource for this request’s tenant (joins the tenant layer by TenantConfig::datasource name). Unknown/absent tenant → default.

pub fn iter(&self) -> impl Iterator<Item = (&'static str, &D)>

Iterate all datasources (default first as “”, then named in deterministic order) — used by the migration runner.

pub async fn acquire( &self, ds: &D, intent: AccessIntent, pin: &ReadAfterWritePin, ) -> Result<D::Conn, DataError>

Acquire a connection with the read-after-write pin applied.