Struct NotifyEvent 

pub struct NotifyEvent {
    pub kind: EventKind,
    pub severity: Severity,
    pub pipeline: String,
    pub row: String,
    pub title: String,
    pub message: String,
    pub details: Map<String, Value>,
    pub run: Option<RunContext>,
}

Available on crate feature notify only.

A single thing worth notifying about.

Fields

kind: EventKind

severity: Severity

pipeline: String

Pipeline name (metric-label identity).

row: String

Matrix row id ("" for non-matrix runs).

title: String

Short one-line summary.

message: String

Human-readable detail.

details: Map<String, Value>

Structured context rendered into channel payloads (never contains secrets — the emit sites pass only safe scalars).

run: Option<RunContext>

Run identity + timing (#480). None for events with no owning invocation (e.g. scheduler_stuck, which is emitted by the scheduler loop itself rather than by a run).

Implementations

impl NotifyEvent

pub fn with_run(self, run: RunContext) -> Self

Stamp run identity + timing onto this event (#480). Emit sites build one RunContext per invocation and apply it to every event they produce.

pub fn with_run_opt(self, run: Option<RunContext>) -> Self

Stamp run identity from an optional context — the shape emit sites actually have, since the notifier is feature-gated and some callers have no run to attribute.

pub fn incident_key(&self) -> String

Correlation key for PagerDuty incident open/resolve pairing and for coalescing per (pipeline, row). A run_success resolves the incident a prior run_failure opened on the same key.

pub fn dedupe_key(&self) -> String

Per-rule coalesce key: the same kind repeating for the same (pipeline, row) coalesces within a rule’s dedupe_window_secs.

pub fn opens_incident(&self) -> bool

True when this event opens an incident (a failure-class event that a later success should resolve).

pub fn closes_incident(&self) -> bool

True when this event closes any open incident for its incident_key.

pub fn run_failure( pipeline: impl Into<String>, row: impl Into<String>, error_kind: &str, message: impl Into<String>, ) -> Self

pub fn run_success( pipeline: impl Into<String>, row: impl Into<String>, rows_written: u64, ) -> Self

pub fn sla_breach( pipeline: impl Into<String>, row: impl Into<String>, sla_kind: &str, message: impl Into<String>, ) -> Self

pub fn circuit_open( pipeline: impl Into<String>, row: impl Into<String>, failures: u32, cooldown_secs: u64, ) -> Self

pub fn contract_abort( pipeline: impl Into<String>, row: impl Into<String>, message: impl Into<String>, ) -> Self

pub fn dlq_threshold( pipeline: impl Into<String>, row: impl Into<String>, records_dlq: u64, ) -> Self

pub fn scheduler_stuck( pipeline: impl Into<String>, message: impl Into<String>, ) -> Self

Trait Implementations

impl Clone for NotifyEvent

fn clone(&self) -> NotifyEvent

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for NotifyEvent

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.