diff --git a/pkg/receive/handler_test.go b/pkg/receive/handler_test.go index b2bb5c043e..028f3a47d5 100644 --- a/pkg/receive/handler_test.go +++ b/pkg/receive/handler_test.go @@ -948,6 +948,7 @@ func benchmarkHandlerMultiTSDBReceiveRemoteWrite(b testutil.TB) { "tenant_id", nil, false, + false, metadata.NoneFunc, ) defer func() { testutil.Ok(b, m.Close()) }() diff --git a/pkg/receive/multitsdb.go b/pkg/receive/multitsdb.go index 114f4d33c1..65935f917f 100644 --- a/pkg/receive/multitsdb.go +++ b/pkg/receive/multitsdb.go @@ -93,6 +93,7 @@ func NewMultiTSDB( tenantLabelName: tenantLabelName, bucket: bucket, allowOutOfOrderUpload: allowOutOfOrderUpload, + uploadCompactedBlocks: allowCompactedUpload, hashFunc: hashFunc, } } diff --git a/pkg/receive/multitsdb_test.go b/pkg/receive/multitsdb_test.go index cc13b5c6ab..1b6bb39af8 100644 --- a/pkg/receive/multitsdb_test.go +++ b/pkg/receive/multitsdb_test.go @@ -51,6 +51,7 @@ func TestMultiTSDB(t *testing.T) { "tenant_id", nil, false, + false, metadata.NoneFunc, ) defer func() { testutil.Ok(t, m.Close()) }() @@ -135,6 +136,7 @@ func TestMultiTSDB(t *testing.T) { "tenant_id", nil, false, + false, metadata.NoneFunc, ) defer func() { testutil.Ok(t, m.Close()) }() @@ -178,6 +180,7 @@ func TestMultiTSDB(t *testing.T) { "tenant_id", nil, false, + false, metadata.NoneFunc, ) defer func() { testutil.Ok(t, m.Close()) }() @@ -445,6 +448,7 @@ func TestMultiTSDBPrune(t *testing.T) { "tenant_id", test.bucket, false, + false, metadata.NoneFunc, ) defer func() { testutil.Ok(t, m.Close()) }() @@ -506,6 +510,7 @@ func TestMultiTSDBRecreatePrunedTenant(t *testing.T) { "tenant_id", objstore.NewInMemBucket(), false, + false, metadata.NoneFunc, ) defer func() { testutil.Ok(t, m.Close()) }() @@ -567,6 +572,7 @@ func TestAlignedHeadFlush(t *testing.T) { "tenant_id", test.bucket, false, + false, metadata.NoneFunc, ) defer func() { testutil.Ok(t, m.Close()) }() @@ -641,6 +647,7 @@ func TestMultiTSDBStats(t *testing.T) { "tenant_id", nil, false, + false, metadata.NoneFunc, ) defer func() { testutil.Ok(t, m.Close()) }() @@ -670,6 +677,7 @@ func TestMultiTSDBWithNilStore(t *testing.T) { "tenant_id", nil, false, + false, metadata.NoneFunc, ) defer func() { testutil.Ok(t, m.Close()) }() @@ -711,6 +719,7 @@ func TestProxyLabelValues(t *testing.T) { "tenant_id", nil, false, + false, metadata.NoneFunc, ) defer func() { testutil.Ok(t, m.Close()) }() @@ -801,6 +810,7 @@ func BenchmarkMultiTSDB(b *testing.B) { "tenant_id", nil, false, + false, metadata.NoneFunc, ) defer func() { testutil.Ok(b, m.Close()) }() diff --git a/pkg/receive/receive_test.go b/pkg/receive/receive_test.go index 55b59d182a..0266923584 100644 --- a/pkg/receive/receive_test.go +++ b/pkg/receive/receive_test.go @@ -814,6 +814,7 @@ func initializeMultiTSDB(dir string) *MultiTSDB { "tenant_id", bucket, false, + false, metadata.NoneFunc, ) diff --git a/pkg/receive/writer_test.go b/pkg/receive/writer_test.go index 34613794b8..9c2ea60490 100644 --- a/pkg/receive/writer_test.go +++ b/pkg/receive/writer_test.go @@ -343,6 +343,7 @@ func TestWriter(t *testing.T) { "tenant_id", nil, false, + false, metadata.NoneFunc, ) t.Cleanup(func() { testutil.Ok(t, m.Close()) }) @@ -435,6 +436,7 @@ func benchmarkWriter(b *testing.B, labelsNum int, seriesNum int, generateHistogr "tenant_id", nil, false, + false, metadata.NoneFunc, ) b.Cleanup(func() { testutil.Ok(b, m.Close()) })