Method drain

nodedb/src/engine/timeseries/memtable.rs:227–267

Drain the memtable, returning all buffered data organized by series.

(&mut self)

    /// Drain the memtable, returning all buffered data organized by series.
    pub fn drain(&mut self) -> Vec<FlushedSeries> {
        let mut result = Vec::with_capacity(self.series.len() + self.evicted.len());
        result.append(&mut self.evicted);

        for (series_id, buf) in self.series.drain() {
            match buf {
                SeriesBuffer::Metric(m) => {
                    let sample_count = m.sample_count;
                    let compressed = m.encoder.finish();
                    result.push(FlushedSeries {
                        series_id,
                        kind: FlushedKind::Metric {
                            gorilla_block: compressed,
                            sample_count,
                        },
                        min_ts: m.min_ts,
                        max_ts: m.max_ts,
                    });
                }
                SeriesBuffer::Log(l) => {
                    result.push(FlushedSeries {
                        series_id,
                        kind: FlushedKind::Log {
                            entries: l.entries,
                            total_bytes: l.total_bytes,
                        },
                        min_ts: l.min_ts,
                        max_ts: l.max_ts,
                    });
                }
            }
        }

        self.series_meta.clear();
        self.memory_bytes = 0;
        self.metric_count = 0;
        self.log_count = 0;
        self.oldest_ts = None;

        result
    }

    pub fn metric_count(&self) -> u64 {
        self.metric_count