Method ensure_buffer

nodedb/src/event/cdc/router.rs:237–244

Ensure a buffer exists for a given key (stream or topic). Creates if missing.

(
        &self,
        tenant_id: u64,
        name: &str,
        retention: &super::stream_def::RetentionConfig,
    )

    /// Ensure a buffer exists for a given key (stream or topic). Creates if missing.
    pub fn ensure_buffer(
        &self,
        tenant_id: u64,
        name: &str,
        retention: &super::stream_def::RetentionConfig,
    ) -> Arc<StreamBuffer> {
        self.get_or_create_buffer(tenant_id, name, retention)
    }

    /// Get a buffer for a stream (if it exists). Used by consumers to poll events.
    pub fn get_buffer(&self, tenant_id: u64, stream_name: &str) -> Option<Arc<StreamBuffer>> {