Function TestBlockBaseQuerierSearchLabelValues

tsdb/querier_test.go:4254–4314

(t *testing.T)

}

func TestBlockBaseQuerierSearchLabelValues(t *testing.T) {
	ctx := t.Context()
	q := newBlockBaseQuerierForSearch(t,
		labels.FromStrings("env", "prod"),
		labels.FromStrings("env", "dev"),
		labels.FromStrings("env", "staging"),
	)

	t.Run("no filter returns all values", func(t *testing.T) {
		rs := q.SearchLabelValues(ctx, "env", nil)
		got := collectSearchResultSet(t, rs)
		gotValues := make([]string, len(got))
		for i, r := range got {
			gotValues[i] = r.Value
			require.Equal(t, 1.0, r.Score)
		}
		slices.Sort(gotValues)
		require.Equal(t, []string{"dev", "prod", "staging"}, gotValues)
	})

	t.Run("filter selects matching values", func(t *testing.T) {
		rs := q.SearchLabelValues(ctx, "env", &storage.SearchHints{Filter: prefixFilter{"p"}})
		got := collectSearchResultSet(t, rs)
		require.Len(t, got, 1)
		require.Equal(t, "prod", got[0].Value)
	})

	t.Run("limit is applied after filtering", func(t *testing.T) {
		rs := q.SearchLabelValues(ctx, "env", &storage.SearchHints{
			Filter: prefixFilter{"p"},
			Limit:  1,
		})
		got := collectSearchResultSet(t, rs)
		require.Equal(t, []storage.SearchResult{{Value: "prod", Score: 1.0}}, got)
	})

	t.Run("limit is applied", func(t *testing.T) {
		rs := q.SearchLabelValues(ctx, "env", &storage.SearchHints{Limit: 2})
		got := collectSearchResultSet(t, rs)
		require.Len(t, got, 2)
	})

	t.Run("unknown label name returns empty", func(t *testing.T) {
		rs := q.SearchLabelValues(ctx, "unknown", nil)
		got := collectSearchResultSet(t, rs)
		require.Empty(t, got)
	})

	t.Run("OrderByValueDesc returns values in reverse alphabetical order", func(t *testing.T) {
		rs := q.SearchLabelValues(ctx, "env", &storage.SearchHints{
			OrderBy: storage.OrderByValueDesc,
		})
		got := collectSearchResultSet(t, rs)
		gotValues := make([]string, len(got))
		for i, r := range got {
			gotValues[i] = r.Value
			require.Equal(t, 1.0, r.Score)
		}