Skip to content

Commit 6d65034

Browse files
committed
Fix linter
1 parent 13c6311 commit 6d65034

File tree

2 files changed

+13
-9
lines changed

2 files changed

+13
-9
lines changed

pkg/store/bucket.go

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -622,7 +622,7 @@ func NewBucketStore(
622622
enableChunkHashCalculation: enableChunkHashCalculation,
623623
seriesBatchSize: SeriesBatchSize,
624624
sortingStrategy: sortingStrategyStore,
625-
lazyRetrievalMaxBufferedResponses: 10,
625+
lazyRetrievalMaxBufferedResponses: 1,
626626
indexHeaderLazyDownloadStrategy: indexheader.AlwaysEagerDownloadIndexHeader,
627627
requestLoggerFunc: NoopRequestLoggerFunc,
628628
}
@@ -1624,6 +1624,10 @@ func (s *BucketStore) Series(req *storepb.SeriesRequest, seriesSrv storepb.Store
16241624
nil,
16251625
)
16261626
} else {
1627+
if s.lazyRetrievalMaxBufferedResponses < 1 {
1628+
// Unit tests hit this path. Using 1 to test corner cases.
1629+
s.lazyRetrievalMaxBufferedResponses = 1
1630+
}
16271631
resp = newLazyRespSet(
16281632
span,
16291633
10*time.Minute,

pkg/store/proxy.go

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -93,14 +93,14 @@ type ProxyStore struct {
9393
selectorLabels labels.Labels
9494
buffers sync.Pool
9595

96-
responseTimeout time.Duration
97-
metrics *proxyStoreMetrics
98-
retrievalStrategy RetrievalStrategy
99-
debugLogging bool
100-
tsdbSelector *TSDBSelector
101-
quorumChunkDedup bool
102-
enableDedup bool
103-
matcherConverter *storepb.MatcherConverter
96+
responseTimeout time.Duration
97+
metrics *proxyStoreMetrics
98+
retrievalStrategy RetrievalStrategy
99+
debugLogging bool
100+
tsdbSelector *TSDBSelector
101+
quorumChunkDedup bool
102+
enableDedup bool
103+
matcherConverter *storepb.MatcherConverter
104104
lazyRetrievalMaxBufferedResponses int
105105
}
106106

0 commit comments

Comments
 (0)