Struct AdmissionController 

pub struct AdmissionController { /* private fields */ }

Admission controller for backpressure under concurrency

Enforces system-wide limits to prevent individual query budgets from being violated due to resource contention.

Implementations

impl AdmissionController

pub fn new(max_global_memory: u64) -> Arc<Self>

Create a new admission controller

pub fn set_class_limit( self: &Arc<Self>, query_class: &str, max_concurrent: usize, )

Set maximum concurrent queries for a class

pub fn try_admit( self: &Arc<Self>, budget: &QueryBudget, ) -> Option<AdmissionTicket>

Try to admit a query

Returns None if admission is denied (should backpressure)

pub fn admit_with_backpressure( self: &Arc<Self>, budget: &QueryBudget, max_wait: Duration, ) -> Option<AdmissionTicket>

Admit a query, waiting with backpressure if necessary

pub fn metrics(&self) -> AdmissionMetrics

Get current system pressure metrics