offsets->offset.

grafana · Oct 22, 2024 · 7ccef62 · 7ccef62
1 parent 72cbfb6
commit 7ccef62
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 6 deletions.
diff --git a/pkg/blockbuilder/scheduler/metrics.go b/pkg/blockbuilder/scheduler/metrics.go
@@ -9,8 +9,8 @@ import (
 
 type schedulerMetrics struct {
 	updateScheduleDuration prometheus.Histogram
-	partitionStartOffsets  *prometheus.GaugeVec
-	partitionEndOffsets    *prometheus.GaugeVec
+	partitionStartOffset   *prometheus.GaugeVec
+	partitionEndOffset     *prometheus.GaugeVec
 }
 
 func newSchedulerMetrics(reg prometheus.Registerer) schedulerMetrics {
@@ -21,11 +21,11 @@ func newSchedulerMetrics(reg prometheus.Registerer) schedulerMetrics {
 
 			NativeHistogramBucketFactor: 1.1,
 		}),
-		partitionStartOffsets: promauto.With(reg).NewGaugeVec(prometheus.GaugeOpts{
+		partitionStartOffset: promauto.With(reg).NewGaugeVec(prometheus.GaugeOpts{
 			Name: "cortex_blockbuilder_scheduler_partition_start_offset",
 			Help: "The observed start offset of each partition.",
 		}, []string{"partition"}),
-		partitionEndOffsets: promauto.With(reg).NewGaugeVec(prometheus.GaugeOpts{
+		partitionEndOffset: promauto.With(reg).NewGaugeVec(prometheus.GaugeOpts{
 			Name: "cortex_blockbuilder_scheduler_partition_end_offset",
 			Help: "The observed end offset of each partition.",
 		}, []string{"partition"}),

diff --git a/pkg/blockbuilder/scheduler/scheduler.go b/pkg/blockbuilder/scheduler/scheduler.go
@@ -93,9 +93,9 @@ func (s *BlockBuilderScheduler) updateSchedule(ctx context.Context) {
 	s.metrics.updateScheduleDuration.Observe(time.Since(startTime).Seconds())
 
 	startOffsets.Each(func(o kadm.ListedOffset) {
-		s.metrics.partitionStartOffsets.WithLabelValues(fmt.Sprint(o.Partition)).Set(float64(o.Offset))
+		s.metrics.partitionStartOffset.WithLabelValues(fmt.Sprint(o.Partition)).Set(float64(o.Offset))
 	})
 	endOffsets.Each(func(o kadm.ListedOffset) {
-		s.metrics.partitionEndOffsets.WithLabelValues(fmt.Sprint(o.Partition)).Set(float64(o.Offset))
+		s.metrics.partitionEndOffset.WithLabelValues(fmt.Sprint(o.Partition)).Set(float64(o.Offset))
 	})
 }