Enum AgentEvent 

pub enum AgentEvent {
    DispatchAck {
        current_closure_at_dispatch: String,
        received_at: DateTime<Utc>,
        seq: u64,
    },
    ActivationStarted {
        started_at: DateTime<Utc>,
        switch_method: String,
        seq: u64,
    },
    ActivationCompleted {
        observed_current_closure: String,
        exit_code: i32,
        completed_at: DateTime<Utc>,
        seq: u64,
    },
    ActivationFailed {
        exit_code: i32,
        stderr_tail: String,
        failed_at: DateTime<Utc>,
        seq: u64,
    },
    ActivationDeferred {
        component: String,
        deferred_at: DateTime<Utc>,
        seq: u64,
    },
    ProbeTopologyDeclared {
        probes: Vec<ProbeTopologyEntryWire>,
        declared_at: DateTime<Utc>,
        seq: u64,
    },
    ProbeObservedFirst {
        probe_name: String,
        mode: ProbeModeWire,
        observed_at: DateTime<Utc>,
        seq: u64,
    },
    ProbeResult {
        probe_name: String,
        mode: ProbeModeWire,
        status: ProbeStatusWire,
        observed_at: DateTime<Utc>,
        failure_reason: Option<String>,
        sub_results: Option<Vec<ProbeSubResultWire>>,
        seq: u64,
    },
    ProbeFailureFirst {
        probe_name: String,
        mode: ProbeModeWire,
        first_failed_at: DateTime<Utc>,
        seq: u64,
    },
    Failed {
        failed_at: DateTime<Utc>,
        sustained_duration_secs: u64,
        failing_probes: Vec<String>,
        policy_applied: OnHealthFailureWire,
        seq: u64,
    },
    RollbackComplete {
        reverted_to_closure: String,
        exit_code: i32,
        completed_at: DateTime<Utc>,
        seq: u64,
    },
    Converged {
        converged_at: DateTime<Utc>,
        current_closure: String,
        seq: u64,
    },
}

Inbound agent events. Mirrors the wire side of nixfleet_state_machine::OutboundAgentEvent (same variant names, camelCase fields per RFC-0005 §4.2).

Variants

DispatchAck

Fields

current_closure_at_dispatch: String

received_at: DateTime<Utc>

seq: u64

ActivationStarted

Fields

started_at: DateTime<Utc>

switch_method: String

seq: u64

ActivationCompleted

Fields

observed_current_closure: String

exit_code: i32

completed_at: DateTime<Utc>

seq: u64

ActivationFailed

Fields

exit_code: i32

stderr_tail: String

failed_at: DateTime<Utc>

seq: u64

ActivationDeferred

LIFT #2 (RFC-0005 §4.2): live activation skipped because component (dbus/systemd/kernel/init) cannot be live-swapped on a running system. Profile + bootloader updated; next reboot completes the activation. Replaces the pre-LIFT-#2 fake ActivationCompleted with exit_code: 0.

Fields

component: String

deferred_at: DateTime<Utc>

seq: u64

ProbeTopologyDeclared

Fields

probes: Vec<ProbeTopologyEntryWire>

declared_at: DateTime<Utc>

seq: u64

ProbeObservedFirst

Fields

probe_name: String

mode: ProbeModeWire

observed_at: DateTime<Utc>

seq: u64

ProbeResult

Fields

probe_name: String

mode: ProbeModeWire

status: ProbeStatusWire

observed_at: DateTime<Utc>

failure_reason: Option<String>

sub_results: Option<Vec<ProbeSubResultWire>>

seq: u64

ProbeFailureFirst

Fields

probe_name: String

mode: ProbeModeWire

first_failed_at: DateTime<Utc>

seq: u64

Failed

Fields

failed_at: DateTime<Utc>

sustained_duration_secs: u64

failing_probes: Vec<String>

policy_applied: OnHealthFailureWire

seq: u64

RollbackComplete

Fields

reverted_to_closure: String

exit_code: i32

completed_at: DateTime<Utc>

seq: u64

Converged

Fields

converged_at: DateTime<Utc>

current_closure: String

seq: u64

Implementations

impl AgentEvent

pub fn seq(&self) -> u64

Trait Implementations

impl Clone for AgentEvent

fn clone(&self) -> AgentEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for AgentEvent

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for AgentEvent

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for AgentEvent

fn eq(&self, other: &AgentEvent) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for AgentEvent

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for AgentEvent