diff options
| author | tv <tv@krebsco.de> | 2026-10-26 04:24:52 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-26 04:24:52 +0100 |
| commit | 2f3d191a12b6e03ef1845c202d15c7b90736558c (patch) | |
| tree | f9e0aecafd5d32f904ffd62893132994ee52958f /src/api/stats/prometheus.rs | |
| parent | 7b7dcb5a77061cb69d368de263a02b5ad26fbf51 (diff) | |
unify peers snapshot logic
Diffstat (limited to 'src/api/stats/prometheus.rs')
| -rw-r--r-- | src/api/stats/prometheus.rs | 8 |
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 { |
