Test continuations and exact revision LISTs

staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go

@@ -1189,6 +1189,310 @@ func RunTestList(ctx context.Context, t *testing.T, store storage.Interface, com
 			expectRVFunc: resourceVersionNotOlderThan(list.ResourceVersion),
 			expectedOut:  []example.Pod{},
 		},
+		// match=Exact
+		{
+			name:        "test List with resource version set before first write, match=Exact",
+			prefix:      "/pods/",
+			pred:        storage.Everything,
+			expectedOut: []example.Pod{},
+			rv:          initialRV,
+			rvMatch:     metav1.ResourceVersionMatchExact,
+			expectRV:    initialRV,
+		},
+		{
+			name:        "test List with resource version of first write, match=Exact",
+			prefix:      "/pods/",
+			pred:        storage.Everything,
+			expectedOut: []example.Pod{*createdPods[0]},
+			rv:          createdPods[0].ResourceVersion,
+			rvMatch:     metav1.ResourceVersionMatchExact,
+			expectRV:    createdPods[0].ResourceVersion,
+		},
+		{
+			name:        "test List with resource version of second write, match=Exact",
+			prefix:      "/pods/",
+			pred:        storage.Everything,
+			expectedOut: []example.Pod{*createdPods[0], *createdPods[1]},
+			rv:          createdPods[1].ResourceVersion,
+			rvMatch:     metav1.ResourceVersionMatchExact,
+			expectRV:    createdPods[1].ResourceVersion,
+		},
+		{
+			name:        "test List with resource version of third write, match=Exact",
+			prefix:      "/pods/",
+			pred:        storage.Everything,
+			expectedOut: []example.Pod{*createdPods[0], *createdPods[1], *createdPods[2]},
+			rv:          createdPods[2].ResourceVersion,
+			rvMatch:     metav1.ResourceVersionMatchExact,
+			expectRV:    createdPods[2].ResourceVersion,
+		},
+		{
+			name:        "test List with resource version of fourth write, match=Exact",
+			prefix:      "/pods/",
+			pred:        storage.Everything,
+			expectedOut: []example.Pod{*createdPods[0], *createdPods[1], *createdPods[2], *createdPods[3]},
+			rv:          createdPods[3].ResourceVersion,
+			rvMatch:     metav1.ResourceVersionMatchExact,
+			expectRV:    createdPods[3].ResourceVersion,
+		},
+		{
+			name:        "test List with resource version of fifth write, match=Exact",
+			prefix:      "/pods/",
+			pred:        storage.Everything,
+			expectedOut: []example.Pod{*createdPods[0], *createdPods[1], *createdPods[2], *createdPods[3], *createdPods[4]},
+			rv:          createdPods[4].ResourceVersion,
+			rvMatch:     metav1.ResourceVersionMatchExact,
+			expectRV:    createdPods[4].ResourceVersion,
+		},
+		{
+			name:        "test List with resource version of six write, match=Exact",
+			prefix:      "/pods/",
+			pred:        storage.Everything,
+			expectedOut: []example.Pod{*createdPods[0], *createdPods[1], *createdPods[2], *createdPods[3], *createdPods[4], *createdPods[5]},
+			rv:          createdPods[5].ResourceVersion,
+			rvMatch:     metav1.ResourceVersionMatchExact,
+			expectRV:    createdPods[5].ResourceVersion,
+		},
+		{
+			name:        "test List with resource version of seventh write, match=Exact",
+			prefix:      "/pods/",
+			pred:        storage.Everything,
+			expectedOut: []example.Pod{*updatedPod, *createdPods[1], *createdPods[2], *createdPods[3], *createdPods[4], *createdPods[5]},
+			rv:          updatedPod.ResourceVersion,
+			rvMatch:     metav1.ResourceVersionMatchExact,
+			expectRV:    updatedPod.ResourceVersion,
+		},
+		{
+			name:        "test List with resource version of eight write, match=Exact",
+			prefix:      "/pods/",
+			pred:        storage.Everything,
+			expectedOut: []example.Pod{*updatedPod, *createdPods[1], *createdPods[2], *createdPods[3], *createdPods[4]},
+			rv:          fmt.Sprint(continueRV),
+			rvMatch:     metav1.ResourceVersionMatchExact,
+			expectRV:    fmt.Sprint(continueRV),
+		},
+		{
+			name:        "test List with resource version after writes, match=Exact",
+			prefix:      "/pods/",
+			pred:        storage.Everything,
+			expectedOut: []example.Pod{*updatedPod, *createdPods[1], *createdPods[2], *createdPods[3], *createdPods[4]},
+			rv:          fmt.Sprint(continueRV + 1),
+			rvMatch:     metav1.ResourceVersionMatchExact,
+			expectRV:    fmt.Sprint(continueRV + 1),
+		},
+		{
+			name:             "test List with future resource version, match=Exact",
+			prefix:           "/pods/",
+			pred:             storage.Everything,
+			rv:               fmt.Sprint(continueRV + 2),
+			rvMatch:          metav1.ResourceVersionMatchExact,
+			expectRVTooLarge: true,
+		},
+		// limit, match=Exact
+		{
+			name:   "test List with limit, resource version of second write, match=Exact",
+			prefix: "/pods/",
+			pred: storage.SelectionPredicate{
+				Label: labels.Everything(),
+				Field: fields.Everything(),
+				Limit: 1,
+			},
+			expectedOut:                []example.Pod{*createdPods[0]},
+			rv:                         createdPods[1].ResourceVersion,
+			expectContinue:             true,
+			expectContinueExact:        encodeContinueOrDie(createdPods[0].Namespace+"/"+createdPods[0].Name+"\x00", int64(mustAtoi(createdPods[1].ResourceVersion))),
+			rvMatch:                    metav1.ResourceVersionMatchExact,
+			expectRV:                   createdPods[1].ResourceVersion,
+			expectedRemainingItemCount: utilpointer.Int64(1),
+		},
+		{
+			name:   "test List with limit, resource version of third write, match=Exact",
+			prefix: "/pods/",
+			pred: storage.SelectionPredicate{
+				Label: labels.Everything(),
+				Field: fields.Everything(),
+				Limit: 2,
+			},
+			rv:                         createdPods[2].ResourceVersion,
+			rvMatch:                    metav1.ResourceVersionMatchExact,
+			expectedOut:                []example.Pod{*createdPods[0], *createdPods[1]},
+			expectContinue:             true,
+			expectContinueExact:        encodeContinueOrDie(createdPods[1].Namespace+"/"+createdPods[1].Name+"\x00", int64(mustAtoi(createdPods[2].ResourceVersion))),
+			expectRV:                   createdPods[2].ResourceVersion,
+			expectedRemainingItemCount: utilpointer.Int64(1),
+		},
+		{
+			name:   "test List with limit, resource version of fourth write, match=Exact",
+			prefix: "/pods/",
+			pred: storage.SelectionPredicate{
+				Label: labels.Everything(),
+				Field: fields.Everything(),
+				Limit: 4,
+			},
+			rv:          createdPods[3].ResourceVersion,
+			rvMatch:     metav1.ResourceVersionMatchExact,
+			expectedOut: []example.Pod{*createdPods[0], *createdPods[1], *createdPods[2], *createdPods[3]},
+			expectRV:    createdPods[3].ResourceVersion,
+		},
+		{
+			name:   "test List with limit, resource version of fifth write, match=Exact",
+			prefix: "/pods/",
+			pred: storage.SelectionPredicate{
+				Label: labels.Everything(),
+				Field: fields.Everything(),
+				Limit: 1,
+			},
+			rv:                         createdPods[4].ResourceVersion,
+			rvMatch:                    metav1.ResourceVersionMatchExact,
+			expectedOut:                []example.Pod{*createdPods[0]},
+			expectRV:                   createdPods[4].ResourceVersion,
+			expectContinue:             true,
+			expectContinueExact:        encodeContinueOrDie(createdPods[0].Namespace+"/"+createdPods[0].Name+"\x00", int64(mustAtoi(createdPods[4].ResourceVersion))),
+			expectedRemainingItemCount: utilpointer.Int64(4),
+		},
+		{
+			name:   "test List with limit, resource version of six write, match=Exact",
+			prefix: "/pods/",
+			pred: storage.SelectionPredicate{
+				Label: labels.Everything(),
+				Field: fields.Everything(),
+				Limit: 2,
+			},
+			rv:                         createdPods[5].ResourceVersion,
+			rvMatch:                    metav1.ResourceVersionMatchExact,
+			expectedOut:                []example.Pod{*createdPods[0], *createdPods[1]},
+			expectRV:                   createdPods[5].ResourceVersion,
+			expectContinue:             true,
+			expectContinueExact:        encodeContinueOrDie(createdPods[1].Namespace+"/"+createdPods[1].Name+"\x00", int64(mustAtoi(createdPods[5].ResourceVersion))),
+			expectedRemainingItemCount: utilpointer.Int64(4),
+		},
+		{
+			name:   "test List with limit, resource version of seventh write, match=Exact",
+			prefix: "/pods/",
+			pred: storage.SelectionPredicate{
+				Label: labels.Everything(),
+				Field: fields.Everything(),
+				Limit: 4,
+			},
+			rv:                         updatedPod.ResourceVersion,
+			rvMatch:                    metav1.ResourceVersionMatchExact,
+			expectedOut:                []example.Pod{*updatedPod, *createdPods[1], *createdPods[5], *createdPods[2]},
+			expectRV:                   updatedPod.ResourceVersion,
+			expectContinue:             true,
+			expectContinueExact:        encodeContinueOrDie(createdPods[2].Namespace+"/"+createdPods[2].Name+"\x00", int64(mustAtoi(updatedPod.ResourceVersion))),
+			expectedRemainingItemCount: utilpointer.Int64(2),
+		},
+		{
+			name:   "test List with limit, resource version of eight write, match=Exact",
+			prefix: "/pods/",
+			pred: storage.SelectionPredicate{
+				Label: labels.Everything(),
+				Field: fields.Everything(),
+				Limit: 8,
+			},
+			expectedOut: []example.Pod{*updatedPod, *createdPods[1], *createdPods[2], *createdPods[3], *createdPods[4]},
+			rv:          fmt.Sprint(continueRV),
+			rvMatch:     metav1.ResourceVersionMatchExact,
+			expectRV:    fmt.Sprint(continueRV),
+		},
+		{
+			name:   "test List with limit, resource version after writes, match=Exact",
+			prefix: "/pods/",
+			pred: storage.SelectionPredicate{
+				Label: labels.Everything(),
+				Field: fields.Everything(),
+				Limit: 1,
+			},
+			rv:                         fmt.Sprint(continueRV + 1),
+			rvMatch:                    metav1.ResourceVersionMatchExact,
+			expectedOut:                []example.Pod{*updatedPod},
+			expectRV:                   fmt.Sprint(continueRV + 1),
+			expectContinue:             true,
+			expectContinueExact:        encodeContinueOrDie(updatedPod.Namespace+"/"+updatedPod.Name+"\x00", int64(continueRV+1)),
+			expectedRemainingItemCount: utilpointer.Int64(4),
+		},
+		// Continue
+		{
+			name:   "test List with continue, resource version of second write",
+			prefix: "/pods/",
+			pred: storage.SelectionPredicate{
+				Label:    labels.Everything(),
+				Field:    fields.Everything(),
+				Limit:    1,
+				Continue: encodeContinueOrDie(createdPods[0].Namespace+"/"+createdPods[0].Name+"\x00", int64(mustAtoi(createdPods[1].ResourceVersion))),
+			},
+			expectedOut: []example.Pod{*createdPods[1]},
+			expectRV:    createdPods[1].ResourceVersion,
+		},
+		{
+			name:   "test List with continue, resource version of third write",
+			prefix: "/pods/",
+			pred: storage.SelectionPredicate{
+				Label:    labels.Everything(),
+				Field:    fields.Everything(),
+				Limit:    2,
+				Continue: encodeContinueOrDie(createdPods[1].Namespace+"/"+createdPods[1].Name+"\x00", int64(mustAtoi(createdPods[2].ResourceVersion))),
+			},
+			expectedOut: []example.Pod{*createdPods[2]},
+			expectRV:    createdPods[2].ResourceVersion,
+		},
+		{
+			name:   "test List with continue, resource version of fifth write",
+			prefix: "/pods/",
+			pred: storage.SelectionPredicate{
+				Label:    labels.Everything(),
+				Field:    fields.Everything(),
+				Limit:    1,
+				Continue: encodeContinueOrDie(createdPods[0].Namespace+"/"+createdPods[0].Name+"\x00", int64(mustAtoi(createdPods[4].ResourceVersion))),
+			},
+			expectedOut:                []example.Pod{*createdPods[1]},
+			expectRV:                   createdPods[4].ResourceVersion,
+			expectContinue:             true,
+			expectContinueExact:        encodeContinueOrDie(createdPods[1].Namespace+"/"+createdPods[1].Name+"\x00", int64(mustAtoi(createdPods[4].ResourceVersion))),
+			expectedRemainingItemCount: utilpointer.Int64(3),
+		},
+		{
+			name:   "test List with continue, resource version of six write",
+			prefix: "/pods/",
+			pred: storage.SelectionPredicate{
+				Label:    labels.Everything(),
+				Field:    fields.Everything(),
+				Limit:    2,
+				Continue: encodeContinueOrDie(createdPods[1].Namespace+"/"+createdPods[1].Name+"\x00", int64(mustAtoi(createdPods[5].ResourceVersion))),
+			},
+			expectedOut:                []example.Pod{*createdPods[5], *createdPods[2]},
+			expectRV:                   createdPods[5].ResourceVersion,
+			expectContinue:             true,
+			expectContinueExact:        encodeContinueOrDie(createdPods[2].Namespace+"/"+createdPods[2].Name+"\x00", int64(mustAtoi(createdPods[5].ResourceVersion))),
+			expectedRemainingItemCount: utilpointer.Int64(2),
+		},
+		{
+			name:   "test List with continue, resource version of seventh write",
+			prefix: "/pods/",
+			pred: storage.SelectionPredicate{
+				Label:    labels.Everything(),
+				Field:    fields.Everything(),
+				Limit:    4,
+				Continue: encodeContinueOrDie(createdPods[2].Namespace+"/"+createdPods[2].Name+"\x00", int64(mustAtoi(updatedPod.ResourceVersion))),
+			},
+			expectedOut: []example.Pod{*createdPods[3], *createdPods[4]},
+			expectRV:    updatedPod.ResourceVersion,
+		},
+		{
+			name:   "test List with continue, resource version after writes",
+			prefix: "/pods/",
+			pred: storage.SelectionPredicate{
+				Label:    labels.Everything(),
+				Field:    fields.Everything(),
+				Limit:    1,
+				Continue: encodeContinueOrDie(updatedPod.Namespace+"/"+updatedPod.Name+"\x00", int64(continueRV+1)),
+			},
+			expectedOut:                []example.Pod{*createdPods[1]},
+			expectRV:                   fmt.Sprint(continueRV + 1),
+			expectContinue:             true,
+			expectContinueExact:        encodeContinueOrDie(createdPods[1].Namespace+"/"+createdPods[1].Name+"\x00", int64(continueRV+1)),
+			expectedRemainingItemCount: utilpointer.Int64(3),
+		},
 	}
 
 	for _, tt := range tests {