Function notify_topic

nodedb/src/event/alert/notify.rs:68–96

Publish alert event to a CDC topic.

(state: &SharedState, tenant_id: u64, topic_name: &str, event: &AlertEvent)

/// Publish alert event to a CDC topic.
fn notify_topic(state: &SharedState, tenant_id: u64, topic_name: &str, event: &AlertEvent) {
    let payload = match sonic_rs::to_string(event) {
        Ok(p) => p,
        Err(e) => {
            warn!(alert = event.alert_name, error = %e, "failed to serialize alert event");
            return;
        }
    };

    match crate::event::topic::publish::publish_to_topic(state, tenant_id, topic_name, &payload) {
        Ok(seq) => {
            info!(
                alert = event.alert_name,
                topic = topic_name,
                seq,
                status = event.status,
                "alert event published to topic"
            );
        }
        Err(e) => {
            warn!(
                alert = event.alert_name,
                topic = topic_name,
                error = %e,
                "failed to publish alert event to topic"
            );
        }
    }
}

/// HTTP POST alert event to a webhook URL using a shared `reqwest::Client`.
///