Method buffer_stats

nodedb/src/event/cdc/router.rs:262–276

Snapshot of all buffer stats (for SHOW CHANGE STREAMS).

(&self)

    /// Snapshot of all buffer stats (for SHOW CHANGE STREAMS).
    pub fn buffer_stats(&self) -> Vec<BufferStats> {
        let buffers = self.buffers.read().unwrap_or_else(|p| p.into_inner());
        buffers
            .iter()
            .map(|((tid, name), buf)| BufferStats {
                tenant_id: *tid,
                stream_name: name.clone(),
                buffered_events: buf.len(),
                total_pushed: buf.total_pushed(),
                total_evicted: buf.total_evicted(),
                earliest_lsn: buf.earliest_lsn(),
                latest_lsn: buf.latest_lsn(),
            })
            .collect()
    }
}

/// Buffer statistics for observability.