Struct DatabaseResolver 

pub struct DatabaseResolver<F>
where
    F: Fn(String) -> Pin<Box<dyn Future<Output = QueryResult<Option<TenantInfo>>> + Send>> + Send + Sync,
{ /* private fields */ }

A resolver that looks up tenants from the database.

Implementations

impl<F> DatabaseResolver<F>

where F: Fn(String) -> Pin<Box<dyn Future<Output = QueryResult<Option<TenantInfo>>> + Send>> + Send + Sync,

pub fn new(query_fn: F) -> Self

Create a new database resolver.

pub fn with_cache_ttl(self, ttl: Duration) -> Self

Set the cache TTL.

pub fn clear_cache(&self)

Clear the cache.

pub fn invalidate(&self, tenant_id: &str)

Invalidate a specific tenant in the cache.

Trait Implementations

impl<F> Debug for DatabaseResolver<F>

where F: Fn(String) -> Pin<Box<dyn Future<Output = QueryResult<Option<TenantInfo>>> + Send>> + Send + Sync,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<F> TenantResolver for DatabaseResolver<F>

where F: Fn(String) -> Pin<Box<dyn Future<Output = QueryResult<Option<TenantInfo>>> + Send>> + Send + Sync,

fn resolve<'life0, 'life1, 'async_trait>( &'life0 self, tenant_id: &'life1 TenantId, ) -> Pin<Box<dyn Future<Output = QueryResult<TenantContext>> + Send + 'async_trait>>

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

Resolve a tenant ID to a full tenant context.

fn validate<'life0, 'life1, 'async_trait>( &'life0 self, tenant_id: &'life1 TenantId, ) -> Pin<Box<dyn Future<Output = QueryResult<bool>> + Send + 'async_trait>>

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

Validate that a tenant exists and is active.

fn schema_for<'life0, 'life1, 'async_trait>( &'life0 self, tenant_id: &'life1 TenantId, ) -> Pin<Box<dyn Future<Output = QueryResult<Option<String>>> + Send + 'async_trait>>

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

Get the schema name for a tenant (schema-based isolation).

fn database_for<'life0, 'life1, 'async_trait>( &'life0 self, tenant_id: &'life1 TenantId, ) -> Pin<Box<dyn Future<Output = QueryResult<Option<String>>> + Send + 'async_trait>>

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

Get the database name for a tenant (database-based isolation).