Struct RuntimeHealth 

pub struct RuntimeHealth { /* private fields */ }

Shared record of background-loop state. Cheap to read from a handler.

Implementations

impl RuntimeHealth

pub fn new() -> Self

pub fn set_started_at(&self, now_unix: i64)

Stamp the process start time. Called once, from main.

pub fn uptime_secs(&self, now_unix: i64) -> Option<i64>

Seconds this process has been alive, or None before it was stamped.

pub fn begin_db_probe(self: &Arc<Self>) -> Result<DbProbeGuard, DbProbe>

Claim the right to run a database probe, or borrow the last verdict.

/health is exempt from the Cloudflare origin lock and is not in the rate limiter’s path list, so it answers unauthenticated requests at whatever rate they arrive. Once it started touching the database, that became a way to spend the 5-connection pool from outside — and the handler’s own timeout then returns the 503 that Fly’s check reads.

This deduplicates CONCURRENT probes rather than caching by time. A time cache would also bound the cost, but it makes a genuinely dead database invisible for the length of the window; this bounds in-flight database work to exactly one probe while leaving every sequential request — Fly’s own, and any operator’s curl — a fresh answer. It is also a better fix than rate-limiting /health, which would risk refusing Fly’s probe.

Returns Err(verdict) when a probe is already running: the caller reports that instead of starting another. Ok(guard) means the caller owns the probe and must report it via the returned guard.

pub fn set_schedulers_enabled(&self, enabled: bool)

Record that the background loops were (or were not) spawned.

pub fn schedulers_enabled(&self) -> bool

pub fn poll_tick_completed(&self, now_unix: i64)

Stamp a completed poll tick at now_unix.

pub fn secs_since_poll_tick(&self, now_unix: i64) -> Option<i64>

Seconds since the last completed poll tick, or None if there has not been one yet.

pub fn set_watermark(&self, paused: bool)

Record the outcome of a watermark check.

Deliberately just the verdict, not the measured size. The size is already in the log line that accompanies a pause, and the two surfaces that read this — /health and /stats — are both reachable without the Cloudflare origin lock or a session, so neither publishes precise internal numbers.

pub fn watermark_paused(&self) -> bool

Whether the watermark is currently pausing new fetches. This is the state in which polled_last_hour falls and overdue climbs for a reason that has nothing to do with the poller being too slow.

Trait Implementations

impl Debug for RuntimeHealth

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

Formats the value using the given formatter.

impl Default for RuntimeHealth

fn default() -> RuntimeHealth

Returns the “default value” for a type.