Skip to content

Commit f574c4e

Browse files
kurkomisiholiman
authored andcommitted
metrics, p2p: add ephemeral registry (#18067)
* metrics, p2p: add ephemeral registry * metrics: fix linter issue
1 parent 870efee commit f574c4e

File tree

2 files changed

+6
-3
lines changed

2 files changed

+6
-3
lines changed

metrics/registry.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -311,7 +311,10 @@ func (r *PrefixedRegistry) UnregisterAll() {
311311
r.underlying.UnregisterAll()
312312
}
313313

314-
var DefaultRegistry Registry = NewRegistry()
314+
var (
315+
DefaultRegistry = NewRegistry()
316+
EphemeralRegistry = NewRegistry()
317+
)
315318

316319
// Call the given function for each registered metric.
317320
func Each(f func(string, interface{})) {

p2p/metrics.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -47,8 +47,8 @@ var (
4747
egressConnectMeter = metrics.NewRegisteredMeter(MetricsOutboundConnects, nil) // Meter counting the egress connections
4848
egressTrafficMeter = metrics.NewRegisteredMeter(MetricsOutboundTraffic, nil) // Meter metering the cumulative egress traffic
4949

50-
PeerIngressRegistry = metrics.NewPrefixedChildRegistry(metrics.DefaultRegistry, MetricsInboundTraffic+"/") // Registry containing the peer ingress
51-
PeerEgressRegistry = metrics.NewPrefixedChildRegistry(metrics.DefaultRegistry, MetricsOutboundTraffic+"/") // Registry containing the peer egress
50+
PeerIngressRegistry = metrics.NewPrefixedChildRegistry(metrics.EphemeralRegistry, MetricsInboundTraffic+"/") // Registry containing the peer ingress
51+
PeerEgressRegistry = metrics.NewPrefixedChildRegistry(metrics.EphemeralRegistry, MetricsOutboundTraffic+"/") // Registry containing the peer egress
5252

5353
meteredPeerFeed event.Feed // Event feed for peer metrics
5454
meteredPeerCount int32 // Actually stored peer connection count

0 commit comments

Comments
 (0)