Function dispatch_notifications

nodedb/src/event/alert/notify.rs:26–65

Dispatch notifications for an alert transition. Sends to all configured targets (TOPIC, WEBHOOK, INSERT INTO). Errors are logged but do not prevent other targets from being notified.

(
    state: &Arc<SharedState>,
    alert: &AlertDef,
    group_key: &str,
    value: f64,
    transition: HysteresisTransition,
    now_ms: u64,
)

/// Sends to all configured targets (TOPIC, WEBHOOK, INSERT INTO).
/// Errors are logged but do not prevent other targets from being notified.
pub async fn dispatch_notifications(
    state: &Arc<SharedState>,
    alert: &AlertDef,
    group_key: &str,
    value: f64,
    transition: HysteresisTransition,
    now_ms: u64,
) {
    let status_str = match transition {
        HysteresisTransition::Fired => "ACTIVE",
        HysteresisTransition::Recovered => "CLEARED",
        HysteresisTransition::NoChange => return, // No notification needed.
    };

    let event = AlertEvent {
        alert_name: alert.name.clone(),
        group_key: group_key.to_string(),
        severity: alert.severity.clone(),
        status: status_str.to_string(),
        value,
        threshold: alert.condition.threshold,
        timestamp_ms: now_ms,
        collection: alert.collection.clone(),
    };

    for target in &alert.notify_targets {
        match target {
            NotifyTarget::Topic { name } => {
                notify_topic(state, alert.tenant_id, name, &event);
            }
            NotifyTarget::Webhook { url } => {
                let timeout = Duration::from_secs(state.tuning.scheduler.webhook_timeout_secs);
                notify_webhook_with_client(state.http_client(), url, &event, timeout).await;
            }
            NotifyTarget::InsertInto { table, columns } => {
                notify_insert(state, alert.tenant_id, &alert.owner, table, columns, &event).await;
            }
        }
    }
}

/// Publish alert event to a CDC topic.
fn notify_topic(state: &SharedState, tenant_id: u64, topic_name: &str, event: &AlertEvent) {