Struct QoSObservation 

pub struct QoSObservation {
    pub latency_ms: f64,
    pub throughput_samples_per_sec: f64,
    pub memory_usage_mb: f64,
    pub cpu_utilization_percent: Option<f64>,
    pub prediction_accuracy: Option<f64>,
    pub stream_synchronization_delay_ms: Option<f64>,
}

One round of observations to evaluate the configured service level objectives against.

None means not measured — the corresponding objective is then skipped rather than being assumed satisfied, so a disabled subsystem never silently produces a clean bill of health.

Fields

latency_ms: f64

Average end-to-end latency (ms).

throughput_samples_per_sec: f64

Achieved throughput (samples/second).

memory_usage_mb: f64

Memory in use (MB).

cpu_utilization_percent: Option<f64>

Measured CPU duty cycle of the streaming path (percent).

prediction_accuracy: Option<f64>

Measured accuracy of the predictive engine in [0, 1].

stream_synchronization_delay_ms: Option<f64>

Measured inter-stream synchronization skew (ms).

Implementations

impl QoSObservation

pub fn from_metrics(metrics: &StreamingMetrics) -> Self

Build an observation from the streaming metrics alone; the fields the metrics cannot speak to are left unmeasured.

Trait Implementations

impl Clone for QoSObservation

fn clone(&self) -> QoSObservation

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for QoSObservation

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

Formats the value using the given formatter.

impl Default for QoSObservation

fn default() -> QoSObservation

Returns the “default value” for a type.