Struct ProbeReading 

pub struct ProbeReading {
    pub probe_source: String,
    pub inputs: Value,
    pub output: Value,
    pub host_received_at: Option<DateTime<Utc>>,
}

One reading produced by a HostProbe::read call.

The mandatory triple per D12: which probe, what concrete inputs it read, and the structured output extracted. host_received_at is stamped by emit_reading at dispatch time, not by the probe itself, so the ordering between “probe ran” and “reading hit the sink” stays observable.

Fields

probe_source: String

Stable identifier for the probe (e.g. "host.fc_metrics", "host.cgroup", "host.nftables", "host.tap_link"). Matches the CloudEvents type suffix after the canonical prefix is stripped.

inputs: Value

Concrete inputs the probe consumed (file path, endpoint, etc.). Audit-replayable: re-reading the same inputs should reproduce the reading on a quiescent system.

output: Value

Structured output extracted from the inputs. Free-form per probe.

host_received_at: Option<DateTime<Utc>>

Wallclock the supervisor stamped at dispatch (not at probe-fire). None until emit_reading runs; Some(_) on every event the sink receives.

Implementations

impl ProbeReading

pub fn new( probe_source: impl Into<String>, inputs: Value, output: Value, ) -> Self

Construct a reading without a host-receive stamp; emit_reading stamps it during dispatch.

Trait Implementations

impl Clone for ProbeReading

fn clone(&self) -> ProbeReading

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ProbeReading

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for ProbeReading

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for ProbeReading

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

where __S: Serializer,

Serialize this value into the given Serde serializer.