Enum OpsEvent 

#[non_exhaustive]
pub enum OpsEvent {
    SupervisorStateChange {
        tenant: Option<TenantId>,
        agent: AgentId,
        state: String,
        reason: Option<String>,
    },
    SupervisorStallDetected {
        tenant: Option<TenantId>,
        agent: AgentId,
        missed_heartbeats: u32,
    },
    KillSwitchTripped {
        tenant: Option<TenantId>,
        trigger: String,
        reason: String,
    },
    GovernorDenial {
        tenant: Option<TenantId>,
        resource: String,
        provider: Option<ProviderId>,
        host: Option<String>,
        reason: String,
    },
    GovernorFence {
        tenant: Option<TenantId>,
        scope: String,
        reason: Option<String>,
    },
    GovernorBudgetSnapshot {
        tenant: Option<TenantId>,
        scope: String,
        remaining: i64,
        limit: i64,
    },
    GateDecision {
        tenant: Option<TenantId>,
        tool: String,
        decision: String,
        gate: String,
        policy_ref: Option<String>,
        reason: Option<String>,
    },
    EscalationRaised {
        tenant: Option<TenantId>,
        ticket: String,
        severity: String,
        reason: String,
        provenance_root: Option<String>,
    },
    EscalationStateChanged {
        tenant: Option<TenantId>,
        ticket: String,
        from: String,
        to: String,
        reason: Option<String>,
    },
    EscalationResolved {
        tenant: Option<TenantId>,
        ticket: String,
        outcome: String,
        reason: Option<String>,
    },
    WorkPlanned {
        tenant: Option<TenantId>,
        work_id: String,
        title: String,
        depends_on: Vec<String>,
    },
    WorkDependencyAdded {
        tenant: Option<TenantId>,
        child: String,
        on: String,
    },
    WorkDispatched {
        tenant: Option<TenantId>,
        work_id: String,
    },
    WorkTransition {
        tenant: Option<TenantId>,
        work_id: String,
        from: String,
        to: String,
        reason: Option<String>,
    },
    HandoffPackaged {
        tenant: Option<TenantId>,
        from_run: String,
        merkle_root: String,
    },
    HandoffDelivered {
        tenant: Option<TenantId>,
        from_run: String,
        to_agent: String,
    },
    HandoffVerified {
        tenant: Option<TenantId>,
        from_run: String,
    },
    HandoffVerificationFailed {
        tenant: Option<TenantId>,
        from_run: Option<String>,
        reason: String,
    },
}

Operational-layer event. Carried inside Episode::Ops(serde_json::Value).

The tenant field is part of the canonical signed payload — chain signatures cover it, so a tampered tenant tag invalidates the chain.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

SupervisorStateChange

Supervisor lifecycle event.

Fields

tenant: Option<TenantId>

Tenant tag for run-scope consistency.

agent: AgentId

Affected agent.

state: String

New state.

reason: Option<String>

Optional human-readable reason.

SupervisorStallDetected

Supervisor detected a stalled agent.

Fields

tenant: Option<TenantId>

Tenant tag.

agent: AgentId

Stalled agent.

missed_heartbeats: u32

Missed heartbeat count.

KillSwitchTripped

Kill-switch tripped.

Fields

tenant: Option<TenantId>

Tenant tag.

trigger: String

Trigger source (programmatic / external / audit).

reason: String

Reason recorded with the trip.

GovernorDenial

Governor denied an LLM or egress acquire.

Fields

tenant: Option<TenantId>

Tenant tag.

resource: String

Resource kind: currently "llm" or "egress". Stringly-typed in v0.2 because the field name was forced by the serde tag collision (see ADR-008). A typed enum may replace this in v0.3.

provider: Option<ProviderId>

Provider id (LLM only).

host: Option<String>

Host (egress only).

reason: String

Reason.

GovernorFence

Governor fenced a scope.

Fields

tenant: Option<TenantId>

Tenant tag.

scope: String

Scope description (formatted).

reason: Option<String>

Optional reason.

GovernorBudgetSnapshot

Periodic budget snapshot.

Fields

tenant: Option<TenantId>

Tenant tag.

scope: String

Scope description.

remaining: i64

Remaining budget.

limit: i64

Limit.

GateDecision

Gate evaluated a tool invocation.

Fields

tenant: Option<TenantId>

Tenant tag.

tool: String

Tool name.

decision: String

allow / deny / require_approval.

gate: String

Gate name that produced the decision.

policy_ref: Option<String>

Optional policy reference (e.g. cedar bundle sha).

reason: Option<String>

Optional reason text.

EscalationRaised

New escalation ticket raised.

Fields

tenant: Option<TenantId>

Tenant tag for run-scope consistency.

ticket: String

Stable ticket identifier (klieo-ops generated).

severity: String

Severity at time of raise.

reason: String

Free-form reason text (already redacted via global Redactor).

provenance_root: Option<String>

Optional Merkle root of the provenance bundle attached to the ticket.

EscalationStateChanged

Escalation state transition (e.g. raised → acknowledged, acknowledged → resolved, or requeued + escalated to a higher severity).

Fields

tenant: Option<TenantId>

Tenant tag.

ticket: String

Ticket identifier.

from: String

From-state label.

to: String

To-state label.

reason: Option<String>

Optional reason / annotation.

EscalationResolved

Escalation resolved with a terminal outcome (Resolved / AutoDenied / TimedOut / Halted).

Fields

tenant: Option<TenantId>

Tenant tag.

ticket: String

Ticket identifier.

outcome: String

Terminal outcome label (e.g. “resolved”, “auto_denied”, “timed_out”, “halted”).

reason: Option<String>

Optional resolution reason text.

WorkPlanned

Work item planned (entered the DAG).

Fields

tenant: Option<TenantId>

Tenant tag.

work_id: String

Work identifier.

title: String

Item title or short label.

depends_on: Vec<String>

Optional list of work_ids this item depends on (declared at plan time).

WorkDependencyAdded

Dependency relationship added between two existing work items.

Fields

tenant: Option<TenantId>

Tenant tag.

child: String

Child work id.

on: String

Dependency parent work id.

WorkDispatched

Work item dispatched (enqueued onto the JobQueue for execution).

Fields

tenant: Option<TenantId>

Tenant tag.

work_id: String

Work identifier.

WorkTransition

Work item state transition.

Fields

tenant: Option<TenantId>

Tenant tag.

work_id: String

Work identifier.

from: String

From-state label.

to: String

To-state label.

reason: Option<String>

Optional reason / annotation.

HandoffPackaged

Handoff envelope packaged and signed.

Fields

tenant: Option<TenantId>

Tenant tag.

from_run: String

Source run id.

merkle_root: String

Hex-encoded Merkle root.

HandoffDelivered

Handoff envelope delivered to a receiver agent.

Fields

tenant: Option<TenantId>

Tenant tag.

from_run: String

Source run id.

to_agent: String

Receiver agent identifier.

HandoffVerified

Handoff verification succeeded.

Fields

tenant: Option<TenantId>

Tenant tag.

from_run: String

Source run id.

HandoffVerificationFailed

Handoff verification failed (bad sig, expired, prefix proof invalid, or redaction schema fail).

Fields

tenant: Option<TenantId>

Tenant tag.

from_run: Option<String>

Source run id (if extractable from the envelope).

reason: String

Free-form reason.

Implementations

impl OpsEvent

pub fn into_episode_payload(self) -> Result<Value, Error>

Convert to the opaque serde_json::Value shape consumed by Episode::Ops. Returns an error only if serde_json cannot serialise the value — practically impossible for this type, but must not panic in production code paths.

pub fn from_episode_payload(v: &Value) -> Option<Self>

Round-trip from an opaque Episode::Ops payload. Returns None if the payload doesn’t match the known shape.

Trait Implementations

impl Clone for OpsEvent

fn clone(&self) -> OpsEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OpsEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for OpsEvent

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for OpsEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.