From 5877dabec0388656d715ee3cc00672e6274403ad Mon Sep 17 00:00:00 2001 From: Lukasz Cwik Date: Wed, 17 Jan 2024 09:17:46 -0800 Subject: [PATCH] Remove in memory sink from fanout and add latency sampling methods --- telemetry/metrics.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/telemetry/metrics.go b/telemetry/metrics.go index c157208979728..ad73804764c70 100644 --- 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 }