fixed sphinx version metrics registration (#5546)

This commit is contained in:
Jędrzej Stuczyński
2025-03-03 17:24:10 +00:00
committed by GitHub
parent 9be9c04f52
commit 7060fa6dad
3 changed files with 10 additions and 3 deletions
+1 -1
View File
@@ -1,6 +1,6 @@
# This file is automatically @generated by Cargo.
# It is not intended for manual editing.
version = 4
version = 3
[[package]]
name = "ahash"
+2 -1
View File
@@ -63,6 +63,7 @@ impl MixingStats {
.or_default()
.forward_packets
.received += 1;
*self.ingress.received_versions.entry(version).or_default() += 1;
}
@@ -213,7 +214,7 @@ impl Display for PacketKind {
PacketKind::Unknown => "unknown".fmt(f),
PacketKind::Outfox => "outfox".fmt(f),
PacketKind::Sphinx(sphinx_version) => {
write!(f, "sphinx-{sphinx_version}")
write!(f, "sphinx_{sphinx_version}")
}
}
}
@@ -291,7 +291,13 @@ impl PrometheusMetric {
}
fn set(&self, value: i64) {
metrics_registry().set(&self.name(), value);
let reg = metrics_registry();
if !reg.set(&self.name(), value) {
if let Some(registrable) = self.to_registrable_metric() {
reg.register_metric(registrable);
reg.set(&self.name(), value);
}
}
}
fn set_float(&self, value: f64) {