Function createSeriesRequest

pkg/querier/blocks_store_queryable.go:1069–1110

(minT, maxT, limit int64, matchers []storepb.LabelMatcher, selectHints *storage.SelectHints, shardingInfo *storepb.ShardInfo, skipChunks bool, blockIDs []ulid.ULID, aggrs []storepb.Aggr, batchSize int64)

}

func createSeriesRequest(minT, maxT, limit int64, matchers []storepb.LabelMatcher, selectHints *storage.SelectHints, shardingInfo *storepb.ShardInfo, skipChunks bool, blockIDs []ulid.ULID, aggrs []storepb.Aggr, batchSize int64) (*storepb.SeriesRequest, error) {
	// Selectively query only specific blocks.
	hints := &hintspb.SeriesRequestHints{
		BlockMatchers: []storepb.LabelMatcher{
			{
				Type:  storepb.LabelMatcher_RE,
				Name:  block.BlockIDLabel,
				Value: strings.Join(convertULIDsToString(blockIDs), "|"),
			},
		},
		EnableQueryStats: true,
	}

	anyHints, err := types.MarshalAny(hints)
	if err != nil {
		return nil, errors.Wrapf(err, "failed to marshal series request hints")
	}

	req := &storepb.SeriesRequest{
		MinTime:                 minT,
		MaxTime:                 maxT,
		Limit:                   limit,
		Matchers:                matchers,
		PartialResponseStrategy: storepb.PartialResponseStrategy_ABORT,
		Hints:                   anyHints,
		SkipChunks:              skipChunks,
		ShardInfo:               shardingInfo,
		// TODO: support more downsample levels when downsampling is supported.
		Aggregates:          aggrs,
		MaxResolutionWindow: downsample.ResLevel0,
		ResponseBatchSize:   batchSize,
	}

	if selectHints != nil {
		req.QueryHints = &storepb.QueryHints{
			ProjectionLabels:  selectHints.ProjectionLabels,
			ProjectionInclude: selectHints.ProjectionInclude,
		}
	}

	return req, nil
}

func createLabelNamesRequest(minT, maxT, limit int64, blockIDs []ulid.ULID, matchers []storepb.LabelMatcher) (*storepb.LabelNamesRequest, error) {
	req := &storepb.LabelNamesRequest{