Struct Incident 

pub struct Incident {

    pub id: Uuid,
    pub org_id: Uuid,
    pub workspace_id: Option<Uuid>,
    pub source: String,
    pub source_ref: Option<String>,
    pub dedupe_key: String,
    pub severity: String,
    pub status: String,
    pub title: String,
    pub description: Option<String>,
    pub postmortem_url: Option<String>,
    pub assigned_to: Option<Uuid>,
    pub acknowledged_at: Option<DateTime<Utc>>,
    pub acknowledged_by: Option<Uuid>,
    pub resolved_at: Option<DateTime<Utc>>,
    pub resolved_by: Option<Uuid>,
    pub created_at: DateTime<Utc>,
    pub updated_at: DateTime<Utc>,
}

Persistent incident row. dedupe_key is source-scoped — the noisy sources (drift detection, observability alerts) collapse repeat fires onto a single open row via the partial-unique index in the migration.

Fields

id: Uuid

org_id: Uuid

workspace_id: Option<Uuid>

source: String

source_ref: Option<String>

dedupe_key: String

severity: String

status: String

title: String

description: Option<String>

postmortem_url: Option<String>

assigned_to: Option<Uuid>

acknowledged_at: Option<DateTime<Utc>>

acknowledged_by: Option<Uuid>

resolved_at: Option<DateTime<Utc>>

resolved_by: Option<Uuid>

created_at: DateTime<Utc>

updated_at: DateTime<Utc>

Implementations

impl Incident

pub async fn list_by_org( pool: &Pool<Postgres>, org_id: Uuid, status_filter: Option<&str>, limit: i64, ) -> Result<Vec<Incident>, Error>

pub async fn find_by_id( pool: &Pool<Postgres>, id: Uuid, ) -> Result<Option<Incident>, Error>

pub async fn raise( pool: &Pool<Postgres>, input: RaiseIncidentInput<'_>, ) -> Result<Incident, Error>

Insert a new incident, or no-op if there’s already an open one with the same (org_id, source, dedupe_key). Returns the incident in either case, so callers always have an id to reference.

Relies on the partial-unique index idx_incidents_open_dedupe — ON CONFLICT DO NOTHING against that index keeps repeated fires idempotent without needing application-side coordination.

pub async fn auto_resolve( pool: &Pool<Postgres>, org_id: Uuid, source: &str, dedupe_key: &str, ) -> Result<u64, Error>

Mark all open incidents matching (org_id, source, dedupe_key) as resolved. Used by sources that auto-resolve when the underlying signal recovers (e.g., next clean drift check).

pub async fn acknowledge( pool: &Pool<Postgres>, id: Uuid, actor_id: Uuid, ) -> Result<Option<Incident>, Error>

pub async fn resolve( pool: &Pool<Postgres>, id: Uuid, actor_id: Uuid, ) -> Result<Option<Incident>, Error>

pub async fn list_events( pool: &Pool<Postgres>, incident_id: Uuid, ) -> Result<Vec<IncidentEvent>, Error>

pub async fn list_pending_dispatch( pool: &Pool<Postgres>, limit: i64, ) -> Result<Vec<Incident>, Error>

Open incidents that haven’t been dispatched to notification channels yet. The dispatcher worker polls this; once it inserts a notification_dispatched incident_event for an incident, that incident drops out of the list.

Capped at limit rows so a backlog can’t OOM the worker.

pub async fn record_notification_attempt( pool: &Pool<Postgres>, incident_id: Uuid, channel_id: Uuid, result: &Value, ) -> Result<(), Error>

Worker-callback: record one dispatch attempt per (incident, channel). result is freeform JSON — typically {"ok": true, "status": 204} for success or {"ok": false, "error": "..."} for failure. Multiple rows per incident are expected (one per channel).

pub async fn mark_dispatched( pool: &Pool<Postgres>, incident_id: Uuid, summary: &Value, ) -> Result<(), Error>

Worker-callback: incident has been processed by the dispatcher. Inserting this row removes the incident from list_pending_dispatch. Idempotent: a duplicate insert is fine — the next poll just finds zero pending rows.

Trait Implementations

impl Clone for Incident

fn clone(&self) -> Incident

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Incident

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for Incident

fn deserialize<__D>( __deserializer: __D, ) -> Result<Incident, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<'a, R> FromRow<'a, R> for Incident

where R: Row, &'a str: ColumnIndex<R>, Uuid: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, Option<Uuid>: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, String: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, Option<String>: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, Option<DateTime<Utc>>: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>, DateTime<Utc>: Decode<'a, <R as Row>::Database> + Type<<R as Row>::Database>,

fn from_row(__row: &'a R) -> Result<Incident, Error>

impl Serialize for Incident

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.