Downsample metrics into fixed time windows.
(
&self,
series_id: SeriesId,
range: &TimeRange,
window_ms: i64,
)
| 123 | |
| 124 | /// Downsample metrics into fixed time windows. |
| 125 | pub fn downsample_metrics( |
| 126 | &self, |
| 127 | series_id: SeriesId, |
| 128 | range: &TimeRange, |
| 129 | window_ms: i64, |
| 130 | ) -> Result<Vec<(i64, f64)>, QueryError> { |
| 131 | let samples = self.scan_metrics(series_id, range)?; |
| 132 | Ok(reader::downsample(&samples, window_ms)) |
| 133 | } |
| 134 | |
| 135 | /// Scan all log entries for a series within a time range. |
| 136 | pub fn scan_logs( |