Struct LoadManager 

pub struct LoadManager { /* private fields */ }

Central load management coordinator.

Combines rate limiting, concurrency control, and load shedding into a single admission control API. Used by the HTTP server and agent loop to degrade gracefully under load.

Implementations

impl LoadManager

pub fn new(config: LoadConfig) -> Self

Create a new load manager from configuration.

pub fn check_admission(&self) -> Admission

Check whether a request should be admitted.

Returns Admission::Allowed if the request can proceed, or a rejection reason if the system is under load.

pub async fn acquire_permit(&self) -> Option<OwnedSemaphorePermit>

Try to acquire a concurrency permit.

Returns Some(permit) if a permit was acquired, or None if the concurrency limit is reached. The permit is automatically returned when dropped.

pub fn record_outcome(&self, outcome: RequestOutcome)

Record a request outcome for error rate tracking.

pub fn set_queue_depth(&self, depth: u64)

Update the queue depth estimate.

pub fn metrics(&self) -> LoadMetrics

Get current load metrics.

Trait Implementations

impl Debug for LoadManager

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

Formats the value using the given formatter.