dsfb-turbine 0.1.0

DSFB Structural Semiotics Engine for Gas Turbine Jet Engine Health Monitoring. A deterministic, read-only, observer-only augmentation layer for typed residual interpretation over existing Engine Health Monitoring (EHM), Gas Path Analysis (GPA), and Prognostics and Health Management (PHM) systems. The core engine is no_std + no_alloc. Unsafe code is forbidden in the library. Dataset loading, fleet evaluation, reporting, and executable examples are std-gated.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47

//! Fleet-level evaluation orchestrator.
//!
//! Runs DSFB pipeline across all engines in a dataset and
//! computes aggregate metrics.

use crate::dataset::cmapss::CmapssDataset;
use crate::pipeline::engine_eval::{evaluate_engine, EngineEvalResult};
use crate::pipeline::metrics::{compute_fleet_metrics, FleetMetrics};
use crate::core::config::DsfbConfig;
use crate::core::channels::{ChannelId, INFORMATIVE_CHANNELS_FD001};

/// Runs the complete fleet evaluation on a C-MAPSS dataset.
pub fn evaluate_fleet(
    dataset: &CmapssDataset,
    config: &DsfbConfig,
    channels: &[ChannelId],
) -> (Vec<EngineEvalResult>, FleetMetrics) {
    let units = dataset.units();
    let mut results = Vec::with_capacity(units.len());

    for &unit in &units {
        // Extract channel data for this unit
        let channel_data: Vec<(ChannelId, Vec<f64>)> = channels.iter()
            .map(|&ch| {
                let vals = dataset.channel_for_unit(unit, ch.cmapss_sensor_index());
                (ch, vals)
            })
            .filter(|(_, vals)| !vals.is_empty())
            .collect();

        if channel_data.is_empty() {
            continue;
        }

        let result = evaluate_engine(unit, &channel_data, config);
        results.push(result);
    }

    let metrics = compute_fleet_metrics(&results);
    (results, metrics)
}

/// Runs the default FD001 evaluation with default configuration.
pub fn evaluate_fd001(dataset: &CmapssDataset) -> (Vec<EngineEvalResult>, FleetMetrics) {
    let config = DsfbConfig::cmapss_fd001_default();
    evaluate_fleet(dataset, &config, INFORMATIVE_CHANNELS_FD001)
}