Function TestExpendedPostingsCache

pkg/ingester/ingester_test.go:6520–6819

(t *testing.T)

}

func TestExpendedPostingsCache(t *testing.T) {
	cfg := defaultIngesterTestConfig(t)
	cfg.BlocksStorageConfig.TSDB.ExpandedCachingExpireInterval = time.Second
	cfg.BlocksStorageConfig.TSDB.BlockRanges = []time.Duration{2 * time.Hour}

	runQuery := func(t *testing.T, ctx context.Context, i *Ingester, matchers []*client.LabelMatcher) []client.TimeSeriesChunk {
		s := &mockQueryStreamServer{ctx: ctx}

		err := i.QueryStream(&client.QueryRequest{
			StartTimestampMs: 0,
			EndTimestampMs:   math.MaxInt64,
			Matchers:         matchers,
		}, s)
		require.NoError(t, err)
		return s.series
	}

	tc := map[string]struct {
		cacheConfig               cortex_tsdb.TSDBPostingsCacheConfig
		expectedBlockPostingCall  int
		expectedHeadPostingCall   int
		shouldExpireDueInactivity bool
	}{
		"cacheDisabled": {
			expectedBlockPostingCall: 0,
			expectedHeadPostingCall:  0,
			cacheConfig: cortex_tsdb.TSDBPostingsCacheConfig{
				Head: cortex_tsdb.PostingsCacheConfig{
					Enabled: false,
				},
				Blocks: cortex_tsdb.PostingsCacheConfig{
					Enabled: false,
				},
			},
		},
		"enabled cache on compacted blocks": {
			expectedBlockPostingCall: 1,
			expectedHeadPostingCall:  0,
			cacheConfig: cortex_tsdb.TSDBPostingsCacheConfig{
				Blocks: cortex_tsdb.PostingsCacheConfig{
					Ttl:      time.Hour,
					MaxBytes: 1024 * 1024 * 1024,
					Enabled:  true,
				},
			},
		},
		"enabled cache on head": {
			expectedBlockPostingCall: 0,
			expectedHeadPostingCall:  1,
			cacheConfig: cortex_tsdb.TSDBPostingsCacheConfig{
				Head: cortex_tsdb.PostingsCacheConfig{
					Ttl:      time.Hour,
					MaxBytes: 1024 * 1024 * 1024,
					Enabled:  true,
				},
			},
		},
		"enabled cache on compacted blocks and head": {