From 44416700f09daf311477575d7d7d59aa0e931b4c Mon Sep 17 00:00:00 2001 From: Edward Welch Date: Wed, 3 Apr 2024 20:10:22 +0000 Subject: [PATCH] fix some tests Signed-off-by: Edward Welch --- pkg/storage/chunk/cache/cache_test.go | 2 +- pkg/storage/chunk/fetcher/fetcher_test.go | 4 ++-- pkg/storage/stores/series_store_write_test.go | 2 +- pkg/storage/util_test.go | 2 +- 4 files changed, 5 insertions(+), 5 deletions(-) diff --git a/pkg/storage/chunk/cache/cache_test.go b/pkg/storage/chunk/cache/cache_test.go index 5595b2df0a6cf..23550dd34965e 100644 --- a/pkg/storage/chunk/cache/cache_test.go +++ b/pkg/storage/chunk/cache/cache_test.go @@ -131,7 +131,7 @@ func testChunkFetcher(t *testing.T, c cache.Cache, chunks []chunk.Chunk) { }, } - fetcher, err := fetcher.New(c, nil, false, s, nil, 10, 100, 0) + fetcher, err := fetcher.New(c, nil, false, s, nil, 0) require.NoError(t, err) defer fetcher.Stop() diff --git a/pkg/storage/chunk/fetcher/fetcher_test.go b/pkg/storage/chunk/fetcher/fetcher_test.go index c6215bde5b980..902b0dae1d743 100644 --- a/pkg/storage/chunk/fetcher/fetcher_test.go +++ b/pkg/storage/chunk/fetcher/fetcher_test.go @@ -193,7 +193,7 @@ func Test(t *testing.T) { assert.NoError(t, chunkClient.PutChunks(context.Background(), test.storeStart)) // Build fetcher - f, err := New(c1, c2, false, sc, chunkClient, 1, 1, test.handoff) + f, err := New(c1, c2, false, sc, chunkClient, test.handoff) assert.NoError(t, err) // Run the test @@ -290,7 +290,7 @@ func BenchmarkFetch(b *testing.B) { _ = chunkClient.PutChunks(context.Background(), test.storeStart) // Build fetcher - f, _ := New(c1, c2, false, sc, chunkClient, 1, 1, test.handoff) + f, _ := New(c1, c2, false, sc, chunkClient, test.handoff) for i := 0; i < b.N; i++ { _, err := f.FetchChunks(context.Background(), test.fetch) diff --git a/pkg/storage/stores/series_store_write_test.go b/pkg/storage/stores/series_store_write_test.go index 823f5bf11f0a1..cac84a17ebfbf 100644 --- a/pkg/storage/stores/series_store_write_test.go +++ b/pkg/storage/stores/series_store_write_test.go @@ -155,7 +155,7 @@ func TestChunkWriter_PutOne(t *testing.T) { idx := &mockIndexWriter{} client := &mockChunksClient{} - f, err := fetcher.New(cache, nil, false, schemaConfig, client, 1, 1, 0) + f, err := fetcher.New(cache, nil, false, schemaConfig, client, 0) require.NoError(t, err) cw := NewChunkWriter(f, schemaConfig, idx, true) diff --git a/pkg/storage/util_test.go b/pkg/storage/util_test.go index 7743bce2fb0f9..db71f70af5a85 100644 --- a/pkg/storage/util_test.go +++ b/pkg/storage/util_test.go @@ -260,7 +260,7 @@ func (m *mockChunkStore) GetChunks(_ context.Context, _ string, _, _ model.Time, panic(err) } - f, err := fetcher.New(cache, nil, false, m.schemas, m.client, 10, 100, 0) + f, err := fetcher.New(cache, nil, false, m.schemas, m.client, 0) if err != nil { panic(err) }