Struct ResourceManager 

pub struct ResourceManager {
    pub backpressure: Arc<BackpressureState>,
    /* private fields */
}

Global resource manager for the runtime.

Tracks all modules and clients, calculates backpressure, and enforces quotas.

Fields

backpressure: Arc<BackpressureState>

Global backpressure state.

Implementations

impl ResourceManager

pub fn new() -> Self

Creates a new resource manager.

pub fn with_default_quota(quota: ModuleQuota) -> Self

Creates a resource manager with custom default quota.

pub fn get_or_create_module(&self, module_name: &str) -> Arc<ModuleResources>

Gets or creates a module resource tracker.

pub fn register_module(&self, module_name: &str, quota: ModuleQuota)

Registers a module with a custom quota.

pub fn can_admit_request(&self, module_name: &str) -> bool

Checks if a request can be admitted.

pub fn record_request_start(&self, module_name: &str) -> bool

Records a request start.

pub fn record_request_end(&self, module_name: &str)

Records a request completion.

pub fn update_backpressure(&self)

Calculates and updates global backpressure.

This should be called periodically (e.g., every 100ms).

pub fn client_connected(&self)

Increments the active client count.

pub fn client_disconnected(&self)

Decrements the active client count.

pub fn stats(&self) -> ResourceManagerStats

Returns statistics about the resource manager.

pub fn spawn_background_task(&self) -> JoinHandle<()>

Starts a background task that periodically resets counters and updates backpressure.

Trait Implementations

impl Debug for ResourceManager

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

Formats the value using the given formatter.

impl Default for ResourceManager

fn default() -> Self

Returns the “default value” for a type.