Skip to content

Commit 1f5291a

Browse files
authored
fix(indexstats): do not collect stats from "IndexStats" lookups for other query types (#12978)
1 parent 8442dca commit 1f5291a

File tree

2 files changed

+4
-23
lines changed

2 files changed

+4
-23
lines changed

pkg/ingester/tailer.go

+2
Original file line numberDiff line numberDiff line change
@@ -6,6 +6,8 @@ import (
66
"sync"
77
"time"
88

9+
"go.uber.org/atomic"
10+
911
"github.com/go-kit/log/level"
1012
"github.com/prometheus/prometheus/model/labels"
1113
"go.uber.org/atomic"

pkg/querier/queryrange/roundtrip.go

+2-23
Original file line numberDiff line numberDiff line change
@@ -274,7 +274,7 @@ func NewMiddleware(
274274
seriesRT = seriesTripperware.Wrap(next)
275275
labelsRT = labelsTripperware.Wrap(next)
276276
instantRT = instantMetricTripperware.Wrap(next)
277-
statsRT = indexStatsTripperware.Wrap(next)
277+
statsRT = base.MergeMiddlewares(StatsCollectorMiddleware(), indexStatsTripperware).Wrap(next)
278278
seriesVolumeRT = seriesVolumeTripperware.Wrap(next)
279279
detectedFieldsRT = detectedFieldsTripperware.Wrap(next)
280280
detectedLabelsRT = detectedLabelsTripperware.Wrap(next)
@@ -1055,22 +1055,6 @@ func NewVolumeTripperware(cfg Config, log log.Logger, limits Limits, schema conf
10551055
), nil
10561056
}
10571057

1058-
func statsTripperware(nextTW base.Middleware) base.Middleware {
1059-
return base.MiddlewareFunc(func(next base.Handler) base.Handler {
1060-
return base.HandlerFunc(func(ctx context.Context, r base.Request) (base.Response, error) {
1061-
cacheMiddlewares := []base.Middleware{
1062-
StatsCollectorMiddleware(),
1063-
nextTW,
1064-
}
1065-
1066-
// wrap nextRT with our new middleware
1067-
return base.MergeMiddlewares(
1068-
cacheMiddlewares...,
1069-
).Wrap(next).Do(ctx, r)
1070-
})
1071-
})
1072-
}
1073-
10741058
func volumeRangeTripperware(nextTW base.Middleware) base.Middleware {
10751059
return base.MiddlewareFunc(func(next base.Handler) base.Handler {
10761060
return base.HandlerFunc(func(ctx context.Context, r base.Request) (base.Response, error) {
@@ -1141,7 +1125,7 @@ func NewIndexStatsTripperware(cfg Config, log log.Logger, limits Limits, schema
11411125
}
11421126
}
11431127

1144-
tw, err := sharedIndexTripperware(
1128+
return sharedIndexTripperware(
11451129
cacheMiddleware,
11461130
cfg,
11471131
merger,
@@ -1152,11 +1136,6 @@ func NewIndexStatsTripperware(cfg Config, log log.Logger, limits Limits, schema
11521136
schema,
11531137
metricsNamespace,
11541138
)
1155-
if err != nil {
1156-
return nil, err
1157-
}
1158-
1159-
return statsTripperware(tw), nil
11601139
}
11611140

11621141
func sharedIndexTripperware(

0 commit comments

Comments
 (0)