Function is_timeseries_cdc_enabled

nodedb/src/control/server/dispatch_utils.rs:369–385

Check if a timeseries collection has CDC enabled. Returns `false` (CDC off) by default for timeseries to prevent high-cardinality metric streams from flooding the ChangeStream bus. Users opt in via `CREATE TIMESERIES name WITH (cdc = 'true')`.

(shared: &SharedState, tenant_id: TenantId, collection: &str)

/// high-cardinality metric streams from flooding the ChangeStream bus.
/// Users opt in via `CREATE TIMESERIES name WITH (cdc = 'true')`.
fn is_timeseries_cdc_enabled(shared: &SharedState, tenant_id: TenantId, collection: &str) -> bool {
    if let Some(catalog) = shared.credentials.catalog()
        && let Ok(Some(coll)) =
            catalog.get_collection(DatabaseId::DEFAULT, tenant_id.as_u64(), collection)
        && coll.collection_type.is_timeseries()
    {
        if let Some(config) = coll.get_timeseries_config()
            && let Some(cdc_val) = config.get("cdc")
        {
            return cdc_val.as_str() == Some("true") || cdc_val.as_bool() == Some(true);
        }
        // Default: CDC off for timeseries.
        return false;
    }
    // Not timeseries or catalog unavailable — allow publishing.
    true
}

#[cfg(test)]
mod collect_budget_tests {