Method query_range

nodedb/src/engine/timeseries/o3_buffer.rs:56–62

Query: find all rows in this buffer that fall within a time range. Returns rows matching the range, sorted by timestamp.

(&mut self, min_ts: i64, max_ts: i64)

    ///
    /// Returns rows matching the range, sorted by timestamp.
    pub fn query_range(&mut self, min_ts: i64, max_ts: i64) -> Vec<&O3Row> {
        self.ensure_sorted();
        self.rows
            .iter()
            .filter(|r| r.timestamp_ms >= min_ts && r.timestamp_ms <= max_ts)
            .collect()
    }

    /// Drain all rows targeting a specific partition (for merge).
    ///