From 7a84e7630f91014fa3b632d8800e9a943003001c Mon Sep 17 00:00:00 2001 From: Marek Siarkowicz Date: Mon, 3 Mar 2025 20:50:37 +0100 Subject: [PATCH] Run lists tests in subtests --- .../pkg/storage/cacher/cacher_test.go | 58 ++++++++----------- 1 file changed, 24 insertions(+), 34 deletions(-) diff --git a/staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_test.go b/staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_test.go index 59fc7183d75..795aea2e636 100644 --- a/staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_test.go +++ b/staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_test.go @@ -177,45 +177,35 @@ func TestListPaging(t *testing.T) { } func TestList(t *testing.T) { - featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.ConsistentListFromCache, false) - ctx, cacher, server, terminate := testSetupWithEtcdServer(t) - t.Cleanup(terminate) - storagetesting.RunTestList(ctx, t, cacher, compactStorage(cacher, server.V3Client.Client), true) + for _, consistentRead := range []bool{true, false} { + t.Run(fmt.Sprintf("ConsistentListFromCache=%v", consistentRead), func(t *testing.T) { + featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.ConsistentListFromCache, consistentRead) + ctx, cacher, server, terminate := testSetupWithEtcdServer(t) + t.Cleanup(terminate) + storagetesting.RunTestList(ctx, t, cacher, compactStorage(cacher, server.V3Client.Client), true) + }) + } } - -func TestListWithConsistentListFromCache(t *testing.T) { - featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.ConsistentListFromCache, true) - ctx, cacher, server, terminate := testSetupWithEtcdServer(t) - t.Cleanup(terminate) - storagetesting.RunTestList(ctx, t, cacher, compactStorage(cacher, server.V3Client.Client), true) -} - func TestConsistentList(t *testing.T) { - featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.ConsistentListFromCache, false) - ctx, cacher, server, terminate := testSetupWithEtcdServer(t) - t.Cleanup(terminate) - storagetesting.RunTestConsistentList(ctx, t, cacher, compactStorage(cacher, server.V3Client.Client), true, false) -} - -func TestConsistentListWithConsistentListFromCache(t *testing.T) { - featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.ConsistentListFromCache, true) - ctx, cacher, server, terminate := testSetupWithEtcdServer(t) - t.Cleanup(terminate) - storagetesting.RunTestConsistentList(ctx, t, cacher, compactStorage(cacher, server.V3Client.Client), true, true) + for _, consistentRead := range []bool{true, false} { + t.Run(fmt.Sprintf("ConsistentListFromCache=%v", consistentRead), func(t *testing.T) { + featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.ConsistentListFromCache, consistentRead) + ctx, cacher, server, terminate := testSetupWithEtcdServer(t) + t.Cleanup(terminate) + storagetesting.RunTestConsistentList(ctx, t, cacher, compactStorage(cacher, server.V3Client.Client), true, consistentRead) + }) + } } func TestGetListNonRecursive(t *testing.T) { - featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.ConsistentListFromCache, false) - ctx, cacher, server, terminate := testSetupWithEtcdServer(t) - t.Cleanup(terminate) - storagetesting.RunTestGetListNonRecursive(ctx, t, compactStorage(cacher, server.V3Client.Client), cacher) -} - -func TestGetListNonRecursiveWithConsistentListFromCache(t *testing.T) { - featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.ConsistentListFromCache, true) - ctx, cacher, server, terminate := testSetupWithEtcdServer(t) - t.Cleanup(terminate) - storagetesting.RunTestGetListNonRecursive(ctx, t, compactStorage(cacher, server.V3Client.Client), cacher) + for _, consistentRead := range []bool{true, false} { + t.Run(fmt.Sprintf("ConsistentListFromCache=%v", consistentRead), func(t *testing.T) { + featuregatetesting.SetFeatureGateDuringTest(t, utilfeature.DefaultFeatureGate, features.ConsistentListFromCache, consistentRead) + ctx, cacher, server, terminate := testSetupWithEtcdServer(t) + t.Cleanup(terminate) + storagetesting.RunTestGetListNonRecursive(ctx, t, compactStorage(cacher, server.V3Client.Client), cacher) + }) + } } func TestGetListRecursivePrefix(t *testing.T) {