update thanos version to latest main

Signed-off-by: Ben Ye <[email protected]>

Author: yeya24

go.mod

@@ -53,7 +53,7 @@ require (
 	github.com/stretchr/testify v1.8.4
 	github.com/thanos-io/objstore v0.0.0-20231112185854-37752ee64d98
 	github.com/thanos-io/promql-engine v0.0.0-20231013104847-4517c0d5f591
-	github.com/thanos-io/thanos v0.32.5-0.20231103115946-463a6ce8b53c
+	github.com/thanos-io/thanos v0.32.5-0.20231120163350-0a4f5ae3310e
 	github.com/uber/jaeger-client-go v2.30.0+incompatible
 	github.com/weaveworks/common v0.0.0-20221201103051-7c2720a9024d
 	go.etcd.io/etcd/api/v3 v3.5.10

go.sum

@@ -1519,8 +1519,8 @@ github.com/thanos-io/objstore v0.0.0-20231112185854-37752ee64d98 h1:gx2MTto1UQRu
 github.com/thanos-io/objstore v0.0.0-20231112185854-37752ee64d98/go.mod h1:JauBAcJ61tRSv9widgISVmA6akQXDeUMXBrVmWW4xog=
 github.com/thanos-io/promql-engine v0.0.0-20231013104847-4517c0d5f591 h1:6bZbFM+Mvy2kL8BeL8TJ5+5pV3sUR2PSLaZyw911rtQ=
 github.com/thanos-io/promql-engine v0.0.0-20231013104847-4517c0d5f591/go.mod h1:vfXJv1JXNdLfHnjsHsLLJl5tyI7KblF76Wo5lZ9YC4Q=
-github.com/thanos-io/thanos v0.32.5-0.20231103115946-463a6ce8b53c h1:hMpXd1ybZB/vnR3+zex93va42rQ++2E0qi2wVSf3AwY=
-github.com/thanos-io/thanos v0.32.5-0.20231103115946-463a6ce8b53c/go.mod h1:q+0MQPBugkBKZBFSOec4WV4EcuKJU6tgMI0i4M2znpY=
+github.com/thanos-io/thanos v0.32.5-0.20231120163350-0a4f5ae3310e h1:ej5fKlojY+r8qty//Q4b7nyNA4QEkJ5uWms77Itf75E=
+github.com/thanos-io/thanos v0.32.5-0.20231120163350-0a4f5ae3310e/go.mod h1:qeDC74QOf5hWzTlvIrLT8WlNGg67nORFON0T2VF4qgg=
 github.com/themihai/gomemcache v0.0.0-20180902122335-24332e2d58ab h1:7ZR3hmisBWw77ZpO1/o86g+JV3VKlk3d48jopJxzTjU=
 github.com/themihai/gomemcache v0.0.0-20180902122335-24332e2d58ab/go.mod h1:eheTFp954zcWZXCU8d0AT76ftsQOTo4DTqkN/h3k1MY=
 github.com/tidwall/pretty v1.0.0/go.mod h1:XNkn88O1ChpSDQmQeStsy+sBenx6DDtFZJxhVysOjyk=

pkg/storage/tsdb/async_op.go

@@ -10,6 +10,7 @@ import (
 	"github.com/prometheus/client_golang/prometheus/promauto"
 	"github.com/prometheus/prometheus/model/labels"
 	"github.com/prometheus/prometheus/storage"
+	"github.com/thanos-io/thanos/pkg/cacheutil"
 	storecache "github.com/thanos-io/thanos/pkg/store/cache"
 )
 
@@ -24,7 +25,7 @@ type multiLevelCache struct {
 
 	fetchLatency         *prometheus.HistogramVec
 	backFillLatency      *prometheus.HistogramVec
-	backfillProcessor    *AsyncOperationProcessor
+	backfillProcessor    *cacheutil.AsyncOperationProcessor
 	backfillDroppedItems *prometheus.CounterVec
 }
 
@@ -79,7 +80,7 @@ func (m *multiLevelCache) FetchMultiPostings(ctx context.Context, blockID ulid.U
 				for lbl, b := range values {
 					if err := m.backfillProcessor.EnqueueAsync(func() {
 						m.caches[i].StorePostings(blockID, lbl, b, tenant)
-					}); errors.Is(err, ErrAsyncBufferFull) {
+					}); errors.Is(err, cacheutil.ErrAsyncBufferFull) {
 						m.backfillDroppedItems.WithLabelValues(cacheTypePostings).Inc()
 					}
 				}
@@ -116,7 +117,7 @@ func (m *multiLevelCache) FetchExpandedPostings(ctx context.Context, blockID uli
 				backFillTimer := prometheus.NewTimer(m.backFillLatency.WithLabelValues(cacheTypeExpandedPostings))
 				if err := m.backfillProcessor.EnqueueAsync(func() {
 					m.caches[i-1].StoreExpandedPostings(blockID, matchers, d, tenant)
-				}); errors.Is(err, ErrAsyncBufferFull) {
+				}); errors.Is(err, cacheutil.ErrAsyncBufferFull) {
 					m.backfillDroppedItems.WithLabelValues(cacheTypeExpandedPostings).Inc()
 				}
 				backFillTimer.ObserveDuration()
@@ -180,7 +181,7 @@ func (m *multiLevelCache) FetchMultiSeries(ctx context.Context, blockID ulid.ULI
 				for ref, b := range values {
 					if err := m.backfillProcessor.EnqueueAsync(func() {
 						m.caches[i].StoreSeries(blockID, ref, b, tenant)
-					}); errors.Is(err, ErrAsyncBufferFull) {
+					}); errors.Is(err, cacheutil.ErrAsyncBufferFull) {
 						m.backfillDroppedItems.WithLabelValues(cacheTypeSeries).Inc()
 					}
 				}
@@ -198,7 +199,7 @@ func newMultiLevelCache(reg prometheus.Registerer, cfg MultiLevelIndexCacheConfi
 
 	return &multiLevelCache{
 		caches:            c,
-		backfillProcessor: NewAsyncOperationProcessor(cfg.MaxAsyncBufferSize, cfg.MaxAsyncConcurrency),
+		backfillProcessor: cacheutil.NewAsyncOperationProcessor(cfg.MaxAsyncBufferSize, cfg.MaxAsyncConcurrency),
 		fetchLatency: promauto.With(reg).NewHistogramVec(prometheus.HistogramOpts{
 			Name:    "cortex_store_multilevel_index_cache_fetch_duration_seconds",
 			Help:    "Histogram to track latency to fetch items from multi level index cache",