From c5f743ef0f91e4afd0661824d4ec7df1483dcbad Mon Sep 17 00:00:00 2001 From: tv Date: Sat, 31 Oct 2026 06:54:59 +0100 Subject: propagate clock figures --- src/api/stats.rs | 5 +++-- src/api/stats/prometheus.rs | 4 ++-- 2 files changed, 5 insertions(+), 4 deletions(-) (limited to 'src/api') diff --git a/src/api/stats.rs b/src/api/stats.rs index d274fd9..558507a 100644 --- a/src/api/stats.rs +++ b/src/api/stats.rs @@ -67,13 +67,14 @@ struct DiskStats { } /// How long changes written elsewhere took from their commit there until applied here, -/// once caught up. Includes the clock skew between the writer and us. +/// once caught up, by the peers' clocks (`swarm::skew`). Includes the writer's clock +/// skew. #[derive(Debug, Serialize)] #[serde(rename_all = "camelCase")] struct PropagationStats { count: u64, sum_ms: u64, - /// Changes stamped later than our clock on arrival (writer's clock ahead). + /// Changes stamped later than their arrival (writer's clock ahead). ahead: u64, /// Not cumulative; the last bucket has no bound. buckets: Vec, diff --git a/src/api/stats/prometheus.rs b/src/api/stats/prometheus.rs index 6774e74..0a1d75d 100644 --- a/src/api/stats/prometheus.rs +++ b/src/api/stats/prometheus.rs @@ -744,7 +744,7 @@ pub(super) fn render(stats: &StatsResponse, list: &PeerListResponse) -> String { out.family( "propagation_delay_seconds", "histogram", - "Time from a change's commit elsewhere until applied here (includes clock skew).", + "Time from a change's commit elsewhere until applied here, by the peers' clocks (includes the writer's clock skew).", ); out.histogram( "propagation_delay_seconds", @@ -759,7 +759,7 @@ pub(super) fn render(stats: &StatsResponse, list: &PeerListResponse) -> String { out.single( "propagation_clock_ahead_total", "counter", - "Changes stamped later than this node's clock on arrival.", + "Changes stamped later than their arrival, by the peers' clocks.", propagation.ahead as f64, ); -- cgit v1.3.1