Struct TenantRegistry 

pub struct TenantRegistry {
    tenants: RwLock<RawRwLock, HashMap<String, Arc<TenantEntry>>>,
    default_quota: ResourceQuota,
    window_duration: Duration,
}

Registry for managing tenants.

Fields

tenants: RwLock<RawRwLock, HashMap<String, Arc<TenantEntry>>>

default_quota: ResourceQuota

window_duration: Duration

Implementations

impl TenantRegistry

pub fn new() -> TenantRegistry

Create a new tenant registry.

pub fn with_default_quota(self, quota: ResourceQuota) -> TenantRegistry

Set default quota for new tenants.

pub fn with_window_duration(self, duration: Duration) -> TenantRegistry

Set rate limit window duration.

pub fn with_tenant( self, tenant_id: impl Into<String>, quota: ResourceQuota, ) -> TenantRegistry

Register a tenant with quota.

pub fn register_tenant( &self, tenant_id: impl Into<String>, quota: ResourceQuota, ) -> Result<(), TenantError>

Register a new tenant.

pub fn get_quota(&self, tenant_id: &str) -> Option<ResourceQuota>

Get a tenant’s quota.

pub fn get_usage(&self, tenant_id: &str) -> Option<ResourceUsage>

Get a tenant’s current usage.

pub fn tenant_exists(&self, tenant_id: &str) -> bool

Check if tenant exists.

pub fn is_tenant_active(&self, tenant_id: &str) -> bool

Check if tenant is active.

pub fn suspend_tenant(&self, tenant_id: &str) -> Result<(), TenantError>

Suspend a tenant. Suspended tenants cannot allocate resources or send messages.

pub fn resume_tenant(&self, tenant_id: &str) -> Result<(), TenantError>

Resume a previously suspended tenant.

pub fn try_allocate_kernel(&self, tenant_id: &str) -> Result<(), TenantError>

Check and increment kernel count.

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

Release a kernel allocation.

pub fn try_allocate_gpu_memory( &self, tenant_id: &str, mb: u64, ) -> Result<(), TenantError>

Check and increment GPU memory.

pub fn release_gpu_memory(&self, tenant_id: &str, mb: u64)

Release GPU memory allocation.

pub fn record_message(&self, tenant_id: &str) -> Result<(), TenantError>

Record a message sent.

pub fn get_utilization(&self, tenant_id: &str) -> Option<QuotaUtilization>

Get utilization for a tenant.

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

Get all tenant IDs.

pub fn tenant_count(&self) -> usize

Get tenant count.

Trait Implementations

impl Default for TenantRegistry

fn default() -> TenantRegistry

Returns the “default value” for a type.