Struct AdmissionController 

pub struct AdmissionController { /* private fields */ }

Thread-safe admission controller backed by per-tenant token buckets.

use oxirs_core::sla::{SlaClass, AdmissionController};

let ctrl = AdmissionController::new();
ctrl.register_tenant("premium_user", SlaClass::Platinum);
assert!(ctrl.try_admit("premium_user").is_ok());

Implementations

impl AdmissionController

pub fn new() -> AdmissionController

Create an empty controller (no tenants registered).

pub fn register_tenant(&self, tenant_id: &str, sla: SlaClass)

Register (or re-register) a tenant with the given SLA class.

Re-registering an existing tenant resets its bucket to full capacity.

pub fn try_admit(&self, tenant_id: &str) -> Result<(), AdmissionError>

Try to admit one query unit (cost = 1.0 token) for tenant_id.

Returns Ok(()) when admitted, Err(AdmissionError) otherwise.

pub fn try_admit_with_cost( &self, tenant_id: &str, cost: f64, ) -> Result<(), AdmissionError>

Try to admit a request with a custom token cost.

pub fn sla_class(&self, tenant_id: &str) -> Option<SlaClass>

Return the SLA class for a registered tenant, if any.

pub fn available_tokens(&self, tenant_id: &str) -> Option<f64>

Return the current available token count for tenant_id.

Returns None when the tenant is not registered.

pub fn tenant_count(&self) -> usize

Return the number of registered tenants.

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

Deregister a tenant. Returns true if the tenant existed.

Trait Implementations

impl Clone for AdmissionController

fn clone(&self) -> AdmissionController

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for AdmissionController

fn default() -> AdmissionController

Returns the “default value” for a type.