From 284f065d7dbf1ae62accb98c5fe5c2a2702d1263 Mon Sep 17 00:00:00 2001 From: Daniel Mancia <21249320+dmanc@users.noreply.github.com> Date: Mon, 6 Jan 2025 15:20:11 -0800 Subject: [PATCH] Add missing objectives to SummaryVec in dispatcher (#1067) --- disperser/controller/dispatcher_metrics.go | 17 ++++++++++------- 1 file changed, 10 insertions(+), 7 deletions(-) diff --git a/disperser/controller/dispatcher_metrics.go b/disperser/controller/dispatcher_metrics.go index 148342198f..00dc79e5a3 100644 --- a/disperser/controller/dispatcher_metrics.go +++ b/disperser/controller/dispatcher_metrics.go @@ -1,10 +1,11 @@ package controller import ( + "time" + "github.com/Layr-Labs/eigenda/common" "github.com/prometheus/client_golang/prometheus" "github.com/prometheus/client_golang/prometheus/promauto" - "time" ) const dispatcherNamespace = "eigenda_dispatcher" @@ -140,9 +141,10 @@ func newDispatcherMetrics(registry *prometheus.Registry) *dispatcherMetrics { putDispersalRequestLatency := promauto.With(registry).NewSummaryVec( prometheus.SummaryOpts{ - Namespace: dispatcherNamespace, - Name: "put_dispersal_latency_ms", - Help: "The time required to put the dispersal request (part of HandleBatch()).", + Namespace: dispatcherNamespace, + Name: "put_dispersal_latency_ms", + Help: "The time required to put the dispersal request (part of HandleBatch()).", + Objectives: objectives, }, []string{}, ) @@ -168,9 +170,10 @@ func newDispatcherMetrics(registry *prometheus.Registry) *dispatcherMetrics { putDispersalResponseLatency := promauto.With(registry).NewSummaryVec( prometheus.SummaryOpts{ - Namespace: dispatcherNamespace, - Name: "put_dispersal_response_latency_ms", - Help: "The time required to put the dispersal response (part of HandleBatch()).", + Namespace: dispatcherNamespace, + Name: "put_dispersal_response_latency_ms", + Help: "The time required to put the dispersal response (part of HandleBatch()).", + Objectives: objectives, }, []string{}, )