Function TestGetPostingCardinality

pkg/ingester/user_state_test.go:284–317

(t *testing.T)

}

func TestGetPostingCardinality(t *testing.T) {
	testErr := errors.New("err")
	for _, tc := range []struct {
		name        string
		p           index.Postings
		cardinality int
		err         error
	}{
		{
			name: "empty",
			p:    index.EmptyPostings(),
		},
		{
			name: "err",
			p:    index.ErrPostings(testErr),
			err:  testErr,
		},
		{
			name:        "cardinality",
			p:           index.NewListPostings([]storage.SeriesRef{1, 2, 3, 4, 5, 6, 7, 8, 9, 10}),
			cardinality: 10,
		},
	} {
		t.Run(tc.name, func(t *testing.T) {
			cnt, err := getPostingCardinality(tc.p)
			if tc.err != nil {
				require.EqualError(t, err, tc.err.Error())
			} else {
				require.NoError(t, err)
				require.Equal(t, tc.cardinality, cnt)
			}
		})
	}
}

type mockIndexReader struct {
	postings map[string]map[string]index.Postings