summaryrefslogtreecommitdiffstats
path: root/src/api/stats/prometheus.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-10-26 04:24:52 +0100
committertv <tv@krebsco.de>2026-10-26 04:24:52 +0100
commit2f3d191a12b6e03ef1845c202d15c7b90736558c (patch)
treef9e0aecafd5d32f904ffd62893132994ee52958f /src/api/stats/prometheus.rs
parent7b7dcb5a77061cb69d368de263a02b5ad26fbf51 (diff)
unify peers snapshot logic
Diffstat (limited to 'src/api/stats/prometheus.rs')
-rw-r--r--src/api/stats/prometheus.rs8
1 files changed, 1 insertions, 7 deletions
diff --git a/src/api/stats/prometheus.rs b/src/api/stats/prometheus.rs
index 07a6cc8..3709ea4 100644
--- a/src/api/stats/prometheus.rs
+++ b/src/api/stats/prometheus.rs
@@ -120,13 +120,7 @@ struct Peer {
async fn peers(state: &AppState) -> Vec<Peer> {
let now = Instant::now();
- let snapshot: Vec<_> = state
- .peer_states
- .read()
- .await
- .iter()
- .map(|(key, peer_state)| (key.clone(), peer_state.clone()))
- .collect();
+ let snapshot = state.peers_snapshot().await;
let mut aliases = crate::swarm::members::aliases(&state.doc.read().await.doc);
let mut peers = Vec::with_capacity(snapshot.len());
for (key, peer_state) in snapshot {