Method get

nodedb/src/event/cdc/registry.rs:108–111

Get a stream definition by name.

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

    /// Get a stream definition by name.
    pub fn get(&self, tenant_id: u64, name: &str) -> Option<ChangeStreamDef> {
        let key = (tenant_id, name.to_string());
        self.read().by_name.get(&key).map(|a| (**a).clone())
    }

    /// Find all streams matching `(tenant_id, collection)`. Returns shared
    /// `Arc<ChangeStreamDef>` handles so the router hot path is