Struct ResourceManager 

pub struct ResourceManager { /* private fields */ }

Resource manager for streaming optimization

Implementations

impl ResourceManager

pub fn new(config: &StreamingConfig) -> Result<Self, String>

Creates a new resource manager

pub fn start_monitoring(&mut self) -> Result<(), String>

Starts resource monitoring.

R4: the previous loop had no way to stop, so the thread outlived the manager. It now polls a shutdown flag on a short tick (independent of monitoring_frequency, which may be minutes) and Self::stop_monitoring joins it.

pub fn stop_monitoring(&mut self) -> Result<(), String>

Signals the monitoring thread to stop and waits for it.

pub fn is_monitoring(&self) -> bool

Whether the background monitor is running.

pub fn collect_resource_usage(&self) -> ResourceUsage

Collects current resource usage from the long-lived probe.

pub fn allocate_resources( &mut self, component_name: &str, memory_mb: usize, cpu_percent: f64, priority: ResourcePriority, ) -> Result<(), String>

Allocates resources for a component

pub fn budget_violations(&self) -> u64

Number of budget violations observed so far (R7).

pub fn budget_penalty(&self) -> f64

Accumulated budget-violation penalty (CF1: ResourceBudgetConstraints::violation_penalty).

pub fn update_utilization(&mut self) -> Result<(), String>

Updates resource utilization tracking.

When no monitoring thread is running this collects a sample itself (throttled to monitoring_frequency). Previously start_monitoring was never called from anywhere, so current_usage stayed at its all-zero Default forever and every consumer of it read zeros.

pub fn has_sufficient_resources_for_processing(&self) -> Result<bool, String>

Checks if sufficient resources are available for processing.

The CPU term is only applied when a real CPU measurement exists; before the probe has two refreshes to compare, the placeholder 0.0 must not be mistaken for “idle”.

pub fn compute_allocation_adaptation( &mut self, ) -> Result<Option<Adaptation<f32>>, String>

Computes resource allocation adaptation

pub fn predict_usage(&self) -> Option<ResourceUsage>

Predicted resource usage prediction_horizon samples ahead, or None when prediction is disabled or there is not enough history (R7).

pub fn prediction_accuracy(&self) -> &HashMap<String, f64>

Mean absolute percentage error of the predictor, per resource (R7).

pub fn trend_analysis(&self) -> &ResourceTrendAnalysis

Current resource trend analysis.

pub fn register_alert_handler(&mut self, handler: Box<dyn AlertHandler>)

Registers a handler invoked for every raised alert.

pub fn active_alerts(&self) -> Vec<ResourceAlert>

Currently unresolved alerts.

pub fn alert_history(&self) -> Vec<ResourceAlert>

Resolved alerts, oldest first.

pub fn apply_allocation_adaptation( &mut self, adaptation: &Adaptation<f32>, ) -> Result<(), String>

Applies resource allocation adaptation

pub fn current_usage(&self) -> Result<ResourceUsage, String>

Gets current resource usage

pub fn get_usage_history(&self, count: usize) -> Vec<ResourceUsage>

Gets resource usage history

pub fn get_diagnostics(&self) -> ResourceDiagnostics

Gets diagnostic information

Trait Implementations

impl Drop for ResourceManager

fn drop(&mut self)

R4: joins the monitoring thread so it cannot outlive the manager.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.