Remove in memory sink from fanout and add latency sampling methods

dydxprotocol · Jan 17, 2024 · 5877dab · 5877dab
1 parent 7f8562d
commit 5877dab
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/telemetry/metrics.go b/telemetry/metrics.go
@@ -135,7 +135,6 @@ func New(cfg Config) (_ *Metrics, rerr error) {
 	}
 
 	m := &Metrics{sink: sink}
-	fanout := metrics.FanoutSink{sink}
 
 	if cfg.PrometheusRetentionTime > 0 {
 		m.prometheusEnabled = true
@@ -148,10 +147,10 @@ func New(cfg Config) (_ *Metrics, rerr error) {
 			return nil, err
 		}
 
-		fanout = append(fanout, promSink)
+		sink = promSink
 	}
 
-	if _, err := metrics.NewGlobal(metricsConf, fanout); err != nil {
+	if _, err := metrics.NewGlobal(metricsConf, sink); err != nil {
 		return nil, err
 	}