Method remove_buffer

nodedb/src/event/cdc/router.rs:254–259

Remove a buffer when a stream is dropped.

(&self, tenant_id: u64, stream_name: &str)

    /// Remove a buffer when a stream is dropped.
    pub fn remove_buffer(&self, tenant_id: u64, stream_name: &str) {
        let key = (tenant_id, stream_name.to_string());
        let mut buffers = self.buffers.write().unwrap_or_else(|p| p.into_inner());
        buffers.remove(&key);
        self.lag_warner.remove_stream(tenant_id, stream_name);
    }

    /// Snapshot of all buffer stats (for SHOW CHANGE STREAMS).
    pub fn buffer_stats(&self) -> Vec<BufferStats> {