Struct Observed 

pub struct Observed<'a> {
    pub key: &'a str,
    pub delete: bool,
    pub doc: Option<&'a Value>,
    pub qos_matches: Option<bool>,
    pub verdict: PayloadVerdict,
    pub wall_unix_s: u64,
}

One sample, as the frontend hands it over.

Fields

key: &'a str

The full wire key.

delete: bool

SampleKind::Delete — a retirement tombstone (RFC 04 §1.2), never a value.

doc: Option<&'a Value>

The structural document, when the bytes carried one. None is undecodable and is counted as such.

qos_matches: Option<bool>

Whether the wire’s QoS axes matched the declared profile; None when the subject declares none this build knows (not judged).

verdict: PayloadVerdict

wall_unix_s: u64

Arrival, unix seconds on the observer’s clock.

Trait Implementations

impl<'a> Clone for Observed<'a>

fn clone(&self) -> Observed<'a>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a> Copy for Observed<'a>

impl<'a> Debug for Observed<'a>

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

Formats the value using the given formatter.