diff --git a/CHANGELOG.md b/CHANGELOG.md index 8fb3173869..f6cf4a5245 100644 --- a/CHANGELOG.md +++ b/CHANGELOG.md @@ -3,6 +3,7 @@ ## master / unreleased * [FEATURE] StoreGateway: Introduces a new parquet mode. #7046 +* [ENHANCEMENT] StoreGateway: Add tracings to parquet mode. #7125 * [ENHANCEMENT] Alertmanager: Upgrade alertmanger to 0.29.0 and add a new incidentIO integration. #7092 * [ENHANCEMENT] Querier: Add a `-querier.parquet-queryable-shard-cache-ttl` flag to add TTL to parquet shard cache. #7098 * [ENHANCEMENT] Ingester: Add `enable_matcher_optimization` config to apply low selectivity matchers lazily. #7063 diff --git a/pkg/storegateway/parquet_bucket_store.go b/pkg/storegateway/parquet_bucket_store.go index df005b01a8..cc7d83f9dc 100644 --- a/pkg/storegateway/parquet_bucket_store.go +++ b/pkg/storegateway/parquet_bucket_store.go @@ -25,6 +25,7 @@ import ( "google.golang.org/grpc/codes" "google.golang.org/grpc/status" + "github.com/cortexproject/cortex/pkg/util/spanlogger" "github.com/cortexproject/cortex/pkg/util/validation" ) @@ -73,12 +74,14 @@ func (p *parquetBucketStore) findParquetBlocks(ctx context.Context, blockMatcher // Series implements the store interface for a single parquet bucket store func (p *parquetBucketStore) Series(req *storepb.SeriesRequest, srv storepb.Store_SeriesServer) (err error) { + spanLog, ctx := spanlogger.New(srv.Context(), "ParquetBucketStore.Series") + defer spanLog.Finish() + matchers, err := storecache.MatchersToPromMatchersCached(p.matcherCache, req.Matchers...) if err != nil { return status.Error(codes.InvalidArgument, err.Error()) } - ctx := srv.Context() resHints := &hintspb.SeriesResponseHints{} var anyHints *types.Any @@ -158,6 +161,9 @@ func (p *parquetBucketStore) Series(req *storepb.SeriesRequest, srv storepb.Stor // LabelNames implements the store interface for a single parquet bucket store func (p *parquetBucketStore) LabelNames(ctx context.Context, req *storepb.LabelNamesRequest) (*storepb.LabelNamesResponse, error) { + spanLog, ctx := spanlogger.New(ctx, "ParquetBucketStore.LabelNames") + defer spanLog.Finish() + matchers, err := storecache.MatchersToPromMatchersCached(p.matcherCache, req.Matchers...) if err != nil { return nil, status.Error(codes.InvalidArgument, err.Error()) @@ -213,6 +219,9 @@ func (p *parquetBucketStore) LabelNames(ctx context.Context, req *storepb.LabelN // LabelValues implements the store interface for a single parquet bucket store func (p *parquetBucketStore) LabelValues(ctx context.Context, req *storepb.LabelValuesRequest) (*storepb.LabelValuesResponse, error) { + spanLog, ctx := spanlogger.New(ctx, "ParquetBucketStore.LabelValues") + defer spanLog.Finish() + matchers, err := storecache.MatchersToPromMatchersCached(p.matcherCache, req.Matchers...) if err != nil { return nil, status.Error(codes.InvalidArgument, err.Error())