Skip to content

Commit 452b2c3

Browse files
committed
Fixed compile error
Signed-off-by: Alex Le <[email protected]>
1 parent 0d2574f commit 452b2c3

File tree

3 files changed

+12
-2
lines changed

3 files changed

+12
-2
lines changed

pkg/compactor/compactor_test.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1602,7 +1602,7 @@ func prepare(t *testing.T, compactorCfg Config, bucketClient objstore.Bucket, li
16021602

16031603
var blocksGrouperFactory BlocksGrouperFactory
16041604
if tsdbGrouper != nil {
1605-
blocksGrouperFactory = func(_ context.Context, _ Config, _ objstore.InstrumentedBucket, _ log.Logger, _ prometheus.Registerer, _, _, _ prometheus.Counter, _ prometheus.Gauge, _ prometheus.Counter, _ prometheus.Counter, _ prometheus.Counter, _ prometheus.Counter, _ *ring.Ring, _ *ring.Lifecycler, _ Limits, _ string) compact.Grouper {
1605+
blocksGrouperFactory = func(_ context.Context, _ Config, _ objstore.InstrumentedBucket, _ log.Logger, _ prometheus.Registerer, _, _, _ prometheus.Counter, _ prometheus.Gauge, _ prometheus.Counter, _ prometheus.Counter, _ prometheus.Counter, _ prometheus.Counter, _ *ring.Ring, _ *ring.Lifecycler, _ Limits, _ string, _ *compact.GatherNoCompactionMarkFilter) compact.Grouper {
16061606
return tsdbGrouper
16071607
}
16081608
} else {

pkg/compactor/shuffle_sharding_grouper_test.go

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1137,6 +1137,10 @@ func TestGroupPartitioning(t *testing.T) {
11371137

11381138
bkt := &bucket.ClientMock{}
11391139

1140+
noCompactFilter := func() map[ulid.ULID]*metadata.NoCompactMark {
1141+
return make(map[ulid.ULID]*metadata.NoCompactMark)
1142+
}
1143+
11401144
ctx, cancel := context.WithCancel(context.Background())
11411145
defer cancel()
11421146
g := NewShuffleShardingGrouper(
@@ -1165,6 +1169,7 @@ func TestGroupPartitioning(t *testing.T) {
11651169
nil,
11661170
nil,
11671171
nil,
1172+
noCompactFilter,
11681173
)
11691174
var testBlocks []*metadata.Meta
11701175
for block, partitionID := range testData.blocks {
@@ -1308,6 +1313,10 @@ func TestPartitionStrategyChange_shouldUseOriginalPartitionedGroup(t *testing.T)
13081313

13091314
ring := &RingMock{}
13101315

1316+
noCompactFilter := func() map[ulid.ULID]*metadata.NoCompactMark {
1317+
return make(map[ulid.ULID]*metadata.NoCompactMark)
1318+
}
1319+
13111320
ctx, cancel := context.WithCancel(context.Background())
13121321
defer cancel()
13131322
return NewShuffleShardingGrouper(
@@ -1336,6 +1345,7 @@ func TestPartitionStrategyChange_shouldUseOriginalPartitionedGroup(t *testing.T)
13361345
nil,
13371346
nil,
13381347
nil,
1348+
noCompactFilter,
13391349
)
13401350
}
13411351

vendor/github.com/thanos-io/thanos/pkg/compact/compact.go

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)