Struct TenantRegistry 

pub struct TenantRegistry {
    tenants: RwLock<RawRwLock, HashMap<u64, Arc<TenantInfo>>>,
    audit_sink: Option<Arc<dyn AuditSink>>,
}

Registry of active tenants with per-tenant quotas and per-engagement cost accounting.

Fields

tenants: RwLock<RawRwLock, HashMap<u64, Arc<TenantInfo>>>

audit_sink: Option<Arc<dyn AuditSink>>

Implementations

impl TenantRegistry

pub fn new() -> TenantRegistry

Create an empty registry with no audit sink.

pub fn with_audit_sink(sink: Arc<dyn AuditSink>) -> TenantRegistry

Create a registry that forwards audit events (cross-tenant attempts, quota violations) to the given sink.

pub fn set_audit_sink(&mut self, sink: Arc<dyn AuditSink>)

Replace the audit sink on an existing registry.

pub fn register( &self, tenant_id: u64, quota: TenantQuota, ) -> Result<(), RingKernelError>

Register a new tenant with the given quota.

pub fn deregister(&self, tenant_id: u64) -> bool

Deregister a tenant, dropping all quota and cost state.

pub fn is_registered(&self, tenant_id: u64) -> bool

Returns true if the tenant is registered.

pub fn get(&self, tenant_id: u64) -> Option<Arc<TenantInfo>>

Get a snapshot of tenant info (fast Arc clone, no lock held).

pub fn tenant_count(&self) -> usize

Number of registered tenants.

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

All registered tenant IDs.

pub fn check_quota( &self, tenant_id: u64, audit_tag: AuditTag, ) -> Result<(), RingKernelError>

Check whether a send from tenant_id with audit_tag is within quota.

pub fn record_message(&self, tenant_id: u64)

Record a message send for rate-limit accounting.

pub fn track_usage( &self, tenant_id: u64, audit_tag: AuditTag, gpu_seconds: Duration, )

Record billable GPU-seconds against a (tenant_id, audit_tag) pair.

pub fn get_engagement_cost(&self, audit_tag: AuditTag) -> Duration

Get total billable duration for a specific engagement across all registered tenants that have reported cost for it.

pub fn get_engagement_cost_for( &self, tenant_id: u64, audit_tag: AuditTag, ) -> Duration

Get billable duration for a specific (tenant_id, engagement_id) pair.

pub fn is_cross_tenant(&self, from: u64, to: u64) -> bool

Returns true if a send would be cross-tenant.

pub fn audit_cross_tenant( &self, from_tenant: u64, to_tenant: u64, source_kernel: &str, destination_kernel: &str, audit_tag: AuditTag, )

Emit an audit event for a cross-tenant K2K send attempt (rejected).

pub fn acquire_kernel_slot(&self, tenant_id: u64) -> Result<(), RingKernelError>

Increment the registered-kernel counter for this tenant, enforcing TenantQuota::max_concurrent_kernels.

pub fn release_kernel_slot(&self, tenant_id: u64)

Release a kernel slot (call on kernel termination / deregister).

Trait Implementations

impl Debug for TenantRegistry

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

Formats the value using the given formatter.

impl Default for TenantRegistry

fn default() -> TenantRegistry

Returns the “default value” for a type.