Enum Staleness 

pub enum Staleness {
    Cached,
    Strict {
        max_cache_age: String,
    },
    Unchecked,
}

Staleness policy declared on a Manifest, forwarded onto each emitted Command. Internally tagged via mode so YAML reads naturally:

staleness:
  mode: strict
  max_cache_age: 5m

Cached and Unchecked carry no payload, so they collapse to just staleness: { mode: cached } / staleness: { mode: unchecked }.

Variants

Cached

Use whatever the agent has cached for script_current / script_status, no age limit. Silently proceed if the entries are missing. Historical default — every pre-v0.26 Manifest reads as this on deserialize, so introducing the field is fully back-compatible.

Strict

Only run when the agent can verify reasonably-fresh KV state. “Reasonably fresh” = the last confirmed connection to the broker happened within max_cache_age (NATS KV watch is push-based, so while connected the cache is provably up to date; the timer only starts when the agent disconnects). When the window expires the agent attempts a live kv.get(); if that also fails the agent publishes a synthetic skipped result with exit_code = 127.

Fields

max_cache_age: String

Humantime duration (e.g. "0s", "5m", "1h"). Required for strict mode — there’s no implicit default because the right answer is workload-specific.

0s is the conservative choice — agent must be online right now. Larger values trade urgency for tolerance to brief network blips.

Unchecked

Skip Layer 2 entirely — don’t look at script_current or script_status. Use only for fully idempotent local scripts where revoke semantics don’t make sense.

Trait Implementations

impl Clone for Staleness

fn clone(&self) -> Staleness

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Staleness

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

Formats the value using the given formatter.

impl Default for Staleness

fn default() -> Staleness

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for Staleness

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for Staleness

fn eq(&self, other: &Staleness) -> 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 Staleness

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

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl Eq for Staleness

impl StructuralPartialEq for Staleness