Method scan_metrics

nodedb/src/engine/timeseries/query.rs:81–112

Scan all metric samples for a series within a time range.

(
        &self,
        series_id: SeriesId,
        range: &TimeRange,
    )

    /// Scan all metric samples for a series within a time range.
    pub fn scan_metrics(
        &self,
        series_id: SeriesId,
        range: &TimeRange,
    ) -> Result<Vec<(i64, f64)>, QueryError> {
        let segments = self.segment_index.query(series_id, range);
        if segments.is_empty() {
            return Ok(Vec::new());
        }

        let mut all_samples = Vec::new();

        for seg in &segments {
            if seg.kind != SegmentKind::Metric {
                continue;
            }

            let path = self.l1_dir.join(&seg.path);
            let data = reader::read_metric_segment(&path)?;

            // Filter to exact time range.
            for (ts, val) in data.samples {
                if range.contains(ts) {
                    all_samples.push((ts, val));
                }
            }
        }

        // Sort by timestamp for ordered output.
        all_samples.sort_by_key(|&(ts, _)| ts);
        Ok(all_samples)
    }

    /// Aggregate metrics for a series within a time range.
    pub fn aggregate_metrics(