@@ -41,9 +41,9 @@ type ringGatherer struct {
41
41
zoneCmp func (a , b string ) int
42
42
43
43
// Metrics.
44
- streams prometheus.Counter
45
- streamsFailed prometheus.Counter
46
- partitionsMissingTotal * prometheus.CounterVec
44
+ streams prometheus.Counter
45
+ streamsFailed prometheus.Counter
46
+ partitionsMissing * prometheus.CounterVec
47
47
}
48
48
49
49
// newRingGatherer returns a new ringGatherer.
@@ -74,7 +74,7 @@ func newRingGatherer(
74
74
Help : "The total number of received streams that could not be checked." ,
75
75
},
76
76
),
77
- partitionsMissingTotal : promauto .With (reg ).NewCounterVec (
77
+ partitionsMissing : promauto .With (reg ).NewCounterVec (
78
78
prometheus.CounterOpts {
79
79
Name : "loki_ingest_limits_frontend_partitions_missing_total" ,
80
80
Help : "The total number of times an instance was missing for a requested partition." ,
@@ -154,7 +154,7 @@ func (g *ringGatherer) doExceedsLimitsRPCs(ctx context.Context, tenant string, s
154
154
partition := int32 (stream .StreamHash % uint64 (g .numPartitions ))
155
155
addr , ok := partitions [partition ]
156
156
if ! ok {
157
- g .partitionsMissingTotal .WithLabelValues (zone ).Inc ()
157
+ g .partitionsMissing .WithLabelValues (zone ).Inc ()
158
158
continue
159
159
}
160
160
instancesForStreams [addr ] = append (instancesForStreams [addr ], stream )
0 commit comments