client-go/consistencydetector: refactor TestDataConsistencyChecker to work with unstructured data

Author: p0lyn0mial

staging/src/k8s.io/client-go/util/consistencydetector/data_consistency_detector_test.go

@@ -34,22 +34,24 @@ func TestDataConsistencyChecker(t *testing.T) {
 	scenarios := []struct {
 		name string
 
-		listResponse   *v1.PodList
-		retrievedItems []*v1.Pod
-		requestOptions metav1.ListOptions
+		lastSyncedResourceVersion string
+		listResponse              runtime.Object
+		retrievedItems            []runtime.Object
+		requestOptions            metav1.ListOptions
 
 		expectedRequestOptions []metav1.ListOptions
 		expectedListRequests   int
 		expectPanic            bool
 	}{
 		{
-			name: "data consistency check won't panic when data is consistent",
+			name:                      "data consistency check won't panic when data is consistent",
+			lastSyncedResourceVersion: "2",
 			listResponse: &v1.PodList{
 				ListMeta: metav1.ListMeta{ResourceVersion: "2"},
 				Items:    []v1.Pod{*makePod("p1", "1"), *makePod("p2", "2")},
 			},
 			requestOptions:       metav1.ListOptions{TimeoutSeconds: ptr.To(int64(39))},
-			retrievedItems:       []*v1.Pod{makePod("p1", "1"), makePod("p2", "2")},
+			retrievedItems:       []runtime.Object{makePod("p1", "1"), makePod("p2", "2")},
 			expectedListRequests: 1,
 			expectedRequestOptions: []metav1.ListOptions{
 				{
@@ -61,13 +63,14 @@ func TestDataConsistencyChecker(t *testing.T) {
 		},
 
 		{
-			name: "legacy, the limit is removed from the list options when it wasn't honored by the watch cache",
+			name:                      "legacy, the limit is removed from the list options when it wasn't honored by the watch cache",
+			lastSyncedResourceVersion: "2",
 			listResponse: &v1.PodList{
 				ListMeta: metav1.ListMeta{ResourceVersion: "2"},
 				Items:    []v1.Pod{*makePod("p1", "1"), *makePod("p2", "2"), *makePod("p3", "3")},
 			},
 			requestOptions:       metav1.ListOptions{ResourceVersion: "0", Limit: 2},
-			retrievedItems:       []*v1.Pod{makePod("p1", "1"), makePod("p2", "2"), makePod("p3", "3")},
+			retrievedItems:       []runtime.Object{makePod("p1", "1"), makePod("p2", "2"), makePod("p3", "3")},
 			expectedListRequests: 1,
 			expectedRequestOptions: []metav1.ListOptions{
 				{
@@ -78,13 +81,14 @@ func TestDataConsistencyChecker(t *testing.T) {
 		},
 
 		{
-			name: "the limit is NOT removed from the list options for non-legacy request",
+			name:                      "the limit is NOT removed from the list options for non-legacy request",
+			lastSyncedResourceVersion: "2",
 			listResponse: &v1.PodList{
 				ListMeta: metav1.ListMeta{ResourceVersion: "2"},
 				Items:    []v1.Pod{*makePod("p1", "1"), *makePod("p2", "2"), *makePod("p3", "3")},
 			},
 			requestOptions:       metav1.ListOptions{ResourceVersion: "2", Limit: 2},
-			retrievedItems:       []*v1.Pod{makePod("p1", "1"), makePod("p2", "2"), makePod("p3", "3")},
+			retrievedItems:       []runtime.Object{makePod("p1", "1"), makePod("p2", "2"), makePod("p3", "3")},
 			expectedListRequests: 1,
 			expectedRequestOptions: []metav1.ListOptions{
 				{
@@ -96,13 +100,14 @@ func TestDataConsistencyChecker(t *testing.T) {
 		},
 
 		{
-			name: "legacy, the limit is NOT removed from the list options when the watch cache is disabled",
+			name:                      "legacy, the limit is NOT removed from the list options when the watch cache is disabled",
+			lastSyncedResourceVersion: "2",
 			listResponse: &v1.PodList{
 				ListMeta: metav1.ListMeta{ResourceVersion: "2"},
 				Items:    []v1.Pod{*makePod("p1", "1"), *makePod("p2", "2"), *makePod("p3", "3")},
 			},
 			requestOptions:       metav1.ListOptions{ResourceVersion: "0", Limit: 5},
-			retrievedItems:       []*v1.Pod{makePod("p1", "1"), makePod("p2", "2"), makePod("p3", "3")},
+			retrievedItems:       []runtime.Object{makePod("p1", "1"), makePod("p2", "2"), makePod("p3", "3")},
 			expectedListRequests: 1,
 			expectedRequestOptions: []metav1.ListOptions{
 				{
@@ -114,7 +119,8 @@ func TestDataConsistencyChecker(t *testing.T) {
 		},
 
 		{
-			name: "data consistency check won't panic when there is no data",
+			name:                      "data consistency check won't panic when there is no data",
+			lastSyncedResourceVersion: "2",
 			listResponse: &v1.PodList{
 				ListMeta: metav1.ListMeta{ResourceVersion: "2"},
 			},
@@ -136,7 +142,8 @@ func TestDataConsistencyChecker(t *testing.T) {
 		},
 
 		{
-			name: "data consistency check won't be performed when ResourceVersion was set to 0",
+			name:                      "data consistency check won't be performed when ResourceVersion was set to 0",
+			lastSyncedResourceVersion: "0",
 			listResponse: &v1.PodList{
 				ListMeta: metav1.ListMeta{ResourceVersion: "0"},
 				Items:    []v1.Pod{*makePod("p1", "1"), *makePod("p2", "2")},
@@ -146,13 +153,14 @@ func TestDataConsistencyChecker(t *testing.T) {
 		},
 
 		{
-			name: "data consistency panics when data is inconsistent",
+			name:                      "data consistency panics when data is inconsistent",
+			lastSyncedResourceVersion: "2",
 			listResponse: &v1.PodList{
 				ListMeta: metav1.ListMeta{ResourceVersion: "2"},
 				Items:    []v1.Pod{*makePod("p1", "1"), *makePod("p2", "2"), *makePod("p3", "3")},
 			},
 			requestOptions:       metav1.ListOptions{TimeoutSeconds: ptr.To(int64(39))},
-			retrievedItems:       []*v1.Pod{makePod("p1", "1"), makePod("p2", "2")},
+			retrievedItems:       []runtime.Object{makePod("p1", "1"), makePod("p2", "2")},
 			expectedListRequests: 1,
 			expectedRequestOptions: []metav1.ListOptions{
 				{
@@ -172,16 +180,16 @@ func TestDataConsistencyChecker(t *testing.T) {
 				scenario.listResponse = &v1.PodList{}
 			}
 			fakeLister := &listWrapper{response: scenario.listResponse}
-			retrievedItemsFunc := func() []*v1.Pod {
+			retrievedItemsFunc := func() []runtime.Object {
 				return scenario.retrievedItems
 			}
 
 			if scenario.expectPanic {
 				require.Panics(t, func() {
-					CheckDataConsistency(ctx, "", scenario.listResponse.ResourceVersion, fakeLister.List, scenario.requestOptions, retrievedItemsFunc)
+					CheckDataConsistency(ctx, "", scenario.lastSyncedResourceVersion, fakeLister.List, scenario.requestOptions, retrievedItemsFunc)
 				})
 			} else {
-				CheckDataConsistency(ctx, "", scenario.listResponse.ResourceVersion, fakeLister.List, scenario.requestOptions, retrievedItemsFunc)
+				CheckDataConsistency(ctx, "", scenario.lastSyncedResourceVersion, fakeLister.List, scenario.requestOptions, retrievedItemsFunc)
 			}
 
 			require.Equal(t, fakeLister.counter, scenario.expectedListRequests)
@@ -218,10 +226,10 @@ func (lw *errorLister) List(_ context.Context, _ metav1.ListOptions) (runtime.Ob
 type listWrapper struct {
 	counter        int
 	requestOptions []metav1.ListOptions
-	response       *v1.PodList
+	response       runtime.Object
 }
 
-func (lw *listWrapper) List(_ context.Context, opts metav1.ListOptions) (*v1.PodList, error) {
+func (lw *listWrapper) List(_ context.Context, opts metav1.ListOptions) (runtime.Object, error) {
 	lw.counter++
 	lw.requestOptions = append(lw.requestOptions, opts)
 	return lw.response, nil