Struct FreshnessInputs 

pub struct FreshnessInputs {
    pub poll_interval: Duration,
    pub ssh_timeout: Duration,
    pub last_poll_duration: Duration,
    pub recent_timeout_count: u32,
    pub host_rtt: Option<Duration>,
    pub concurrency_pressure: f64,
    pub age: Option<Duration>,
}

Raw inputs to the freshness model. All durations are observer-side facts.

Fields

poll_interval: Duration

Base poll cadence.

ssh_timeout: Duration

Per-poll SSH timeout.

last_poll_duration: Duration

Wall-clock duration of the most recent poll cycle (a slow loop runs long; this is the primary “observer is behind” signal).

recent_timeout_count: u32

Consecutive/recent poll timeouts observed for this worker.

host_rtt: Option<Duration>

Round-trip latency to the worker host, if known (“host distance”).

concurrency_pressure: f64

Poll-permit-pool saturation in [0.0, 1.0] (1.0 = fully saturated).

age: Option<Duration>

Age of the worker’s latest telemetry sample. None = no sample yet.

Implementations

impl FreshnessInputs

pub fn new( poll_interval: Duration, ssh_timeout: Duration, age: Duration, ) -> Self

Minimal constructor for a worker with a known sample age and no adversity (no timeouts, no measured RTT, idle poller, on-pace loop).

Trait Implementations

impl Clone for FreshnessInputs

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for FreshnessInputs

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

Formats the value using the given formatter.