Struct EndpointHealth 

pub struct EndpointHealth {
    pub status: HealthStatus,
    pub consecutive_fails: u8,
    pub consecutive_successes: u8,
    pub last_probe_unix: Option<i64>,
}

Persisted health state for a single Endpoint. Kept inline in the reachable_at JSONB so a control-plane restart doesn’t reset the debounce counters; this means a flapping endpoint that was about to flip Unhealthy keeps its accrued failure count across deploys.

Fields

status: HealthStatus

consecutive_fails: u8

Count of consecutive failed probes since the last success. Caps at EndpointHealth::FAIL_THRESHOLD (any higher is irrelevant — the endpoint is already Unhealthy).

consecutive_successes: u8

Count of consecutive successful probes since the last failure. Caps at EndpointHealth::SUCCESS_THRESHOLD.

last_probe_unix: Option<i64>

Unix seconds of the most recent probe attempt. None if the background monitor hasn’t run yet.

Implementations

impl EndpointHealth

pub const FAIL_THRESHOLD: u8 = 3

Consecutive failures required to flip Healthy → Unhealthy (ADR-0021).

pub const SUCCESS_THRESHOLD: u8 = 2

Consecutive successes required to flip Unhealthy → Healthy (ADR-0021). Deliberately higher friction than the failure threshold — a flapping endpoint should not race a recipient’s connection attempt.

pub fn fresh_healthy(now_unix: i64) -> Self

Initial health for an endpoint just admitted by the CP’s admission-time /healthz probe.

pub fn on_probe_success(self, now_unix: i64) -> Self

Fold a successful probe into this state. Returns self for ergonomic fold/for reassignment in loops.

pub fn on_probe_failure(self, now_unix: i64) -> Self

Fold a failed probe into this state.

pub fn is_healthy(&self) -> bool

True iff the endpoint is currently classified Healthy.

Trait Implementations

impl Clone for EndpointHealth

fn clone(&self) -> EndpointHealth

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EndpointHealth

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for EndpointHealth

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

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for EndpointHealth

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

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 EndpointHealth

impl StructuralPartialEq for EndpointHealth