From b31ad2e7e9fc7d2d774718422e46fe6f16c86f0e Mon Sep 17 00:00:00 2001 From: Csaba Kiraly Date: Fri, 25 Apr 2025 00:55:28 +0200 Subject: [PATCH] eth: fixup per-peer metrics registration Signed-off-by: Csaba Kiraly --- eth/protocols/eth/peer_metrics.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/eth/protocols/eth/peer_metrics.go b/eth/protocols/eth/peer_metrics.go index 7716b2a682..68f74b9b99 100644 --- a/eth/protocols/eth/peer_metrics.go +++ b/eth/protocols/eth/peer_metrics.go @@ -34,9 +34,9 @@ func newPeerMeters(base string, r metrics.Registry) *peerMeters { txReceived: metrics.NewRegisteredMeter(base+"/txReceived", r), txSent: metrics.NewRegisteredMeter(base+"/txSent", r), - txReplyInMeter: metrics.NewRegisteredMeter(base+"/eth/fetcher/transaction/replies/in", nil), - txReplyKnownMeter: metrics.NewRegisteredMeter(base+"/eth/fetcher/transaction/replies/known", nil), - txReplyUnderpricedMeter: metrics.NewRegisteredMeter(base+"/eth/fetcher/transaction/replies/underpriced", nil), - txReplyOtherRejectMeter: metrics.NewRegisteredMeter(base+"/eth/fetcher/transaction/replies/otherreject", nil), + txReplyInMeter: metrics.NewRegisteredMeter(base+"/eth/fetcher/transaction/replies/in", r), + txReplyKnownMeter: metrics.NewRegisteredMeter(base+"/eth/fetcher/transaction/replies/known", r), + txReplyUnderpricedMeter: metrics.NewRegisteredMeter(base+"/eth/fetcher/transaction/replies/underpriced", r), + txReplyOtherRejectMeter: metrics.NewRegisteredMeter(base+"/eth/fetcher/transaction/replies/otherreject", r), } }