Enum Condition 

pub enum Condition {
    RateAbove {
        selector: String,
        hz: f64,
    },
    RateBelow {
        selector: String,
        hz: f64,
    },
    SilentFor {
        selector: String,
        for_s: f64,
    },
    InvalidPayload {
        selector: String,
    },
    QosMismatch {
        selector: String,
    },
    DoctorCheck {
        check: CheckId,
    },
    OriginDown {
        origin: String,
    },
    Dropped,
}

Available on crate feature decode only.

The closed condition vocabulary (#227), over the existing observation surface. Each variant names what firing means; the drop rules are in the judge functions this module documents.

Variants

RateAbove

Samples on selector rode above hz over the evaluation window. Firing is positive evidence, conclusive even under drops (a drop only hides more); ok under drops is unobservable — the true rate is higher than what was counted (O6).

Fields

selector: String

hz: f64

RateBelow

Samples on selector rode below hz. A shortfall under drops is unobservable — the dropped samples could have filled it (O6); enough observed is conclusive ok regardless.

Fields

selector: String

hz: f64

SilentFor

No sample matched selector for at least for_s seconds. Silence is a completeness claim — it counts what did NOT happen — so it is provable only over a drop-free span at least for_s long (O6), and only once the observer has watched that long (O4).

Fields

selector: String

for_s: f64

InvalidPayload

An observed payload on selector did not reach crate::Verdict::Valid (#159) — Invalid and NotValidated both count: asking for validity and getting “unknowable” is not valid. Scoped to what was observed and checked; the ok state claims “nothing checked failed”, never “nothing invalid rode” — the drop count rides in the evidence.

Fields

selector: String

QosMismatch

An observed sample on selector did not ride its registry-declared QoS profile (RFC 04 §3). Same per-observed-sample scope as Condition::InvalidPayload; samples with no declared profile are unjudgeable and counted in the evidence, not the state.

Fields

selector: String

DoctorCheck

A doctor run reported at least one finding with this check id (the stable crate::report::CheckId vocabulary). A failed doctor run is unobservable for every doctor condition — never ok.

Fields

check: CheckId

OriginDown

The origin holds no alive token on the liveliness roster (RFC 04 §5). A roster that could not be asked is unobservable — silence is not a verdict (RFC 05 §3.1).

Fields

origin: String

Dropped

The observer itself dropped samples this window (RFC 09 §5.1 O6) — self-knowledge, so never unobservable.

Implementations

impl Condition

pub fn parse(rule: &str) -> Result<Condition>

Parse one rule: whitespace-separated, kind first (Zenoh key expressions cannot contain whitespace, so the split is unambiguous). The vocabulary is closed; anything else is an error that spells it.

pub fn selector(&self) -> Option<&str>

The wire selector this condition observes, when it observes one.

pub fn judge(&self, ev: &TickEvidence<'_>) -> Eval

Judge one observation window. None for the conditions that are not window-scoped (Condition::DoctorCheck, Condition::OriginDown). Judge this condition against everything one tick observed.

The single entry point, and why run_watchdog has no expects left (#352). The three judges below each returned None for the variants they do not own, which forced the caller to assert a partition the compiler could not see — four times, every one discharging the same claim. This match is the partition, and each arm hands its judge exactly the evidence that judge needs, so none of them has a None to return.

pub fn judge_window(&self, w: &CondWindow) -> Option<Eval>

pub fn judge_roster( &self, roster: Result<&BTreeMap<String, Vec<String>>, &str>, ) -> Option<Eval>

Judge a roster ask. None unless this is Condition::OriginDown. Err is the ask failing, which is unobservable — silence is not a verdict (RFC 05 §3.1).

pub fn judge_doctor(&self, outcome: Result<&DoctorReport, &str>) -> Option<Eval>

Judge a doctor run. None unless this is Condition::DoctorCheck. A failed run is unobservable for every doctor condition — never ok.

Trait Implementations

impl Clone for Condition

fn clone(&self) -> Condition

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Condition

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

Formats the value using the given formatter.

impl Display for Condition

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

The canonical rule spelling — Condition::parse round-trips it, and it is the rule field of every Transition.

impl PartialEq for Condition

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for Condition