Function TestUpdateCompacted

tempodb/blocklist/list_test.go:238–306

(t *testing.T)

}

func TestUpdateCompacted(t *testing.T) {
	var (
		_1 = compactedMeta("00000000-0000-0000-0000-000000000001")
		_2 = compactedMeta("00000000-0000-0000-0000-000000000002")
		_3 = compactedMeta("00000000-0000-0000-0000-000000000003")
	)

	tests := []struct {
		name     string
		existing []*backend.CompactedBlockMeta
		add      []*backend.CompactedBlockMeta
		remove   []*backend.CompactedBlockMeta
		expected []*backend.CompactedBlockMeta
	}{
		{
			name:     "all nil",
			existing: nil,
			add:      nil,
			expected: nil,
		},
		{
			name:     "add to nil",
			existing: nil,
			add:      []*backend.CompactedBlockMeta{_1},
			expected: []*backend.CompactedBlockMeta{_1},
		},
		{
			name:     "add to existing",
			existing: []*backend.CompactedBlockMeta{_1},
			add:      []*backend.CompactedBlockMeta{_2},
			expected: []*backend.CompactedBlockMeta{_1, _2},
		},
		{
			name:     "add already exists",
			existing: []*backend.CompactedBlockMeta{_1},
			add:      []*backend.CompactedBlockMeta{_1, _2},
			expected: []*backend.CompactedBlockMeta{_1, _2},
		},
		{
			name:     "add and remove",
			existing: []*backend.CompactedBlockMeta{_1, _2},
			add:      []*backend.CompactedBlockMeta{_3},
			remove:   []*backend.CompactedBlockMeta{_2},
			expected: []*backend.CompactedBlockMeta{_1, _3},
		},
		{
			name:     "not added if also removed",
			existing: []*backend.CompactedBlockMeta{_1},
			add:      []*backend.CompactedBlockMeta{_2},
			remove:   []*backend.CompactedBlockMeta{_2},
			expected: []*backend.CompactedBlockMeta{_1},
		},
	}

	for _, tt := range tests {
		t.Run(tt.name, func(t *testing.T) {
			l := New()