Function newBlockBaseQuerierForSearch

tsdb/querier_test.go:4191–4207

(t *testing.T, labelSets ...labels.Labels)

}

func newBlockBaseQuerierForSearch(t *testing.T, labelSets ...labels.Labels) *blockBaseQuerier {
	t.Helper()
	ix := newMockIndex()
	// Group series refs by label for writing postings.
	postings := make(map[labels.Label][]storage.SeriesRef)
	for i, ls := range labelSets {
		ref := storage.SeriesRef(i)
		require.NoError(t, ix.AddSeries(ref, ls))
		ls.Range(func(lbl labels.Label) {
			postings[lbl] = append(postings[lbl], ref)
		})
	}
	for lbl, refs := range postings {
		require.NoError(t, ix.WritePostings(lbl.Name, lbl.Value, index.NewListPostings(refs)))
	}
	return &blockBaseQuerier{index: ix, chunks: nil, tombstones: tombstones.NewMemTombstones()}
}

func collectSearchResultSet(t *testing.T, rs storage.SearchResultSet) []storage.SearchResult {
	t.Helper()