Function TestLeveledCompactor

tsdb/compact_test.go:178–446

(t *testing.T)

}

func TestLeveledCompactor(t *testing.T) {
	// Tests for the private plan() method.
	t.Run("plan", func(t *testing.T) {
		// This mimics our default ExponentialBlockRanges with min block size equals to 20.
		compactor, err := NewLeveledCompactor(context.Background(), nil, nil, []int64{
			20,
			60,
			180,
			540,
			1620,
		}, nil, nil)
		require.NoError(t, err)

		cases := map[string]struct {
			metas    []dirMeta
			expected []string
		}{
			"Outside Range": {
				metas: []dirMeta{
					metaRange("1", 0, 20, nil),
				},
				expected: nil,
			},
			"We should wait for four blocks of size 20 to appear before compacting.": {
				metas: []dirMeta{
					metaRange("1", 0, 20, nil),
					metaRange("2", 20, 40, nil),
				},
				expected: nil,
			},
			`We should wait for a next block of size 20 to appear before compacting
			the existing ones. We have three, but we ignore the fresh one from WAl`: {
				metas: []dirMeta{
					metaRange("1", 0, 20, nil),
					metaRange("2", 20, 40, nil),
					metaRange("3", 40, 60, nil),
				},
				expected: nil,
			},
			"Block to fill the entire parent range appeared – should be compacted": {
				metas: []dirMeta{
					metaRange("1", 0, 20, nil),
					metaRange("2", 20, 40, nil),
					metaRange("3", 40, 60, nil),
					metaRange("4", 60, 80, nil),
				},
				expected: []string{"1", "2", "3"},
			},
			`Block for the next parent range appeared with gap with size 20. Nothing will happen in the first one
			anymore but we ignore fresh one still, so no compaction`: {
				metas: []dirMeta{
					metaRange("1", 0, 20, nil),
					metaRange("2", 20, 40, nil),
					metaRange("3", 60, 80, nil),
				},
				expected: nil,
			},
			`Block for the next parent range appeared, and we have a gap with size 20 between second and third block.