Register a flushed segment.
(&mut self, series_id: SeriesId, seg: SegmentRef)
| 27 | |
| 28 | /// Register a flushed segment. |
| 29 | pub fn add(&mut self, series_id: SeriesId, seg: SegmentRef) { |
| 30 | self.total_bytes += seg.size_bytes; |
| 31 | self.total_segments += 1; |
| 32 | self.entries |
| 33 | .entry(series_id) |
| 34 | .or_default() |
| 35 | .insert(seg.min_ts, seg); |
| 36 | } |
| 37 | |
| 38 | /// Find segments overlapping a time range for a given series. |
| 39 | pub fn query(&self, series_id: SeriesId, range: &TimeRange) -> Vec<&SegmentRef> { |