chore: adjust buckets for histogram metrics (#1145)

Signed-off-by: Derek Wang <[email protected]>
numaproj · Oct 3, 2023 · 17bd2f2 · 17bd2f2
1 parent 2d4eab9
commit 17bd2f2
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 7 deletions.
diff --git a/pkg/forward/metrics.go b/pkg/forward/metrics.go
@@ -119,23 +119,23 @@ var forwardAChunkProcessingTime = promauto.NewHistogramVec(prometheus.HistogramO
 	Subsystem: "forwarder",
 	Name:      "forward_chunk_processing_time",
 	Help:      "Processing times of the entire forward a chunk (100 microseconds to 20 minutes)",
-	Buckets:   prometheus.ExponentialBucketsRange(100, 60000000*20, 60),
+	Buckets:   prometheus.ExponentialBucketsRange(100, 60000000*20, 10),
 }, []string{metrics.LabelVertex, metrics.LabelPipeline, metrics.LabelPartitionName})
 
 // udfProcessingTime is a histogram to Observe UDF Processing times as a whole
 var udfProcessingTime = promauto.NewHistogramVec(prometheus.HistogramOpts{
 	Subsystem: "forwarder",
 	Name:      "udf_processing_time",
 	Help:      "Processing times of UDF (100 microseconds to 15 minutes)",
-	Buckets:   prometheus.ExponentialBucketsRange(100, 60000000*15, 60),
+	Buckets:   prometheus.ExponentialBucketsRange(100, 60000000*15, 10),
 }, []string{metrics.LabelVertex, metrics.LabelPipeline, metrics.LabelPartitionName})
 
 // concurrentUDFProcessingTime is a histogram to Observe UDF Processing times as a whole
 var concurrentUDFProcessingTime = promauto.NewHistogramVec(prometheus.HistogramOpts{
 	Subsystem: "forwarder",
 	Name:      "concurrent_udf_processing_time",
 	Help:      "Processing times of Concurrent UDF (100 microseconds to 20 minutes)",
-	Buckets:   prometheus.ExponentialBucketsRange(100, 60000000*20, 60),
+	Buckets:   prometheus.ExponentialBucketsRange(100, 60000000*20, 10),
 }, []string{metrics.LabelVertex, metrics.LabelPipeline, metrics.LabelPartitionName})
 
 // udfReadMessagesCount is used to indicate the number of messages read by UDF

diff --git a/pkg/sinks/forward/metrics.go b/pkg/sinks/forward/metrics.go
@@ -112,5 +112,5 @@ var forwardAChunkProcessingTime = promauto.NewHistogramVec(prometheus.HistogramO
 	Subsystem: "sink_forwarder",
 	Name:      "forward_chunk_processing_time",
 	Help:      "Processing times of the entire forward a chunk (100 microseconds to 20 minutes)",
-	Buckets:   prometheus.ExponentialBucketsRange(100, 60000000*20, 60),
+	Buckets:   prometheus.ExponentialBucketsRange(100, 60000000*20, 10),
 }, []string{metrics.LabelVertex, metrics.LabelPipeline, metrics.LabelPartitionName})
diff --git a/pkg/sources/forward/metrics.go b/pkg/sources/forward/metrics.go
@@ -112,23 +112,23 @@ var forwardAChunkProcessingTime = promauto.NewHistogramVec(prometheus.HistogramO
 	Subsystem: "source_forwarder",
 	Name:      "forward_chunk_processing_time",
 	Help:      "Processing times of the entire forward a chunk (100 microseconds to 20 minutes)",
-	Buckets:   prometheus.ExponentialBucketsRange(100, 60000000*20, 60),
+	Buckets:   prometheus.ExponentialBucketsRange(100, 60000000*20, 10),
 }, []string{metrics.LabelVertex, metrics.LabelPipeline, metrics.LabelPartitionName})
 
 // transformerProcessingTime is a histogram to Observe Source Transformer Processing times as a whole
 var transformerProcessingTime = promauto.NewHistogramVec(prometheus.HistogramOpts{
 	Subsystem: "source_forwarder",
 	Name:      "transformer_processing_time",
 	Help:      "Processing times of source transformer (100 microseconds to 15 minutes)",
-	Buckets:   prometheus.ExponentialBucketsRange(100, 60000000*15, 60),
+	Buckets:   prometheus.ExponentialBucketsRange(100, 60000000*15, 10),
 }, []string{metrics.LabelVertex, metrics.LabelPipeline, metrics.LabelPartitionName})
 
 // concurrentTransformerProcessingTime is a histogram to Observe Source Transformer Processing times as a whole
 var concurrentTransformerProcessingTime = promauto.NewHistogramVec(prometheus.HistogramOpts{
 	Subsystem: "source_forwarder",
 	Name:      "concurrent_transformer_processing_time",
 	Help:      "Processing times of Concurrent source transformer (100 microseconds to 20 minutes)",
-	Buckets:   prometheus.ExponentialBucketsRange(100, 60000000*20, 60),
+	Buckets:   prometheus.ExponentialBucketsRange(100, 60000000*20, 10),
 }, []string{metrics.LabelVertex, metrics.LabelPipeline, metrics.LabelPartitionName})
 
 // transformerReadMessagesCount is used to indicate the number of messages read by source transformer