Struct MeasurementCorrelationAnalyzer 

pub struct MeasurementCorrelationAnalyzer {
    pub n_measurements: usize,
    pub correlation_window: usize,
}

Analyses pairwise correlations among measurement channels to detect coordinated attacks.

A coordinated FDI attack on multiple sensors often breaks the expected correlation structure; this analyzer computes the Frobenius distance between a current correlation matrix and a baseline.

Fields

n_measurements: usize

Number of measurement channels.

correlation_window: usize

Number of most-recent time steps used for rolling correlation.

Implementations

impl MeasurementCorrelationAnalyzer

pub fn new(n_measurements: usize, window: usize) -> Self

Create an analyzer for n_measurements channels with a rolling window.

pub fn compute_correlation(&self, history: &[Vec<f64>]) -> Vec<Vec<f64>>

Compute the n × n Pearson correlation matrix from measurement history.

history[i][t] is the value of measurement channel i at time t. The last correlation_window time steps are used.

pub fn detect_correlation_change( &self, current_window: &[Vec<f64>], baseline_correlation: &[Vec<f64>], ) -> f64

Detect a structural change in measurement correlations.

Computes the current correlation matrix from current_window and returns the Frobenius norm of the difference against baseline_correlation.

Trait Implementations

impl Clone for MeasurementCorrelationAnalyzer

fn clone(&self) -> MeasurementCorrelationAnalyzer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MeasurementCorrelationAnalyzer

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for MeasurementCorrelationAnalyzer

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for MeasurementCorrelationAnalyzer

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.