Merge pull request kubernetes#91505 from jpbetz/rv-semantics

Consistent Resource Version Semantics for List

Author: k8s-ci-robot

api/openapi-spec/swagger.json

@@ -64,8 +64,9 @@ var _ Leases = &storageLeases{}
 func (s *storageLeases) ListLeases() ([]string, error) {
 	ipInfoList := &corev1.EndpointsList{}
 	storageOpts := storage.ListOptions{
-		ResourceVersion: "0",
-		Predicate:       storage.Everything,
+		ResourceVersion:      "0",
+		ResourceVersionMatch: metav1.ResourceVersionMatchNotOlderThan,
+		Predicate:            storage.Everything,
 	}
 	if err := s.storage.List(apirequest.NewDefaultContext(), s.baseKey, storageOpts, ipInfoList); err != nil {
 		return nil, err

pkg/master/reconcilers/lease.go

@@ -5,7 +5,8 @@
   "fieldSelector": "3",
   "watch": true,
   "resourceVersion": "4",
-  "timeoutSeconds": 1002466899136229878,
-  "limit": 5339971464584210463,
+  "resourceVersionMatch": "Exact",
+  "timeoutSeconds": 6780787122834727873,
+  "limit": 3549865785210165515,
   "continue": "5"
 }

staging/src/k8s.io/api/testdata/HEAD/core.v1.ListOptions.json

@@ -3,7 +3,8 @@ continue: "5"
 fieldSelector: "3"
 kind: ListOptions
 labelSelector: "2"
-limit: 5339971464584210463
+limit: 3549865785210165515
 resourceVersion: "4"
-timeoutSeconds: 1002466899136229878
+resourceVersionMatch: Exact
+timeoutSeconds: 6780787122834727873
 watch: true

staging/src/k8s.io/api/testdata/HEAD/core.v1.ListOptions.pb

@@ -215,6 +215,10 @@ func v1FuzzerFuncs(codecs runtimeserializer.CodecFactory) []interface{} {
 				j.Finalizers = nil
 			}
 		},
+		func(j *metav1.ResourceVersionMatch, c fuzz.Continue) {
+			matches := []metav1.ResourceVersionMatch{"", metav1.ResourceVersionMatchExact, metav1.ResourceVersionMatchNotOlderThan}
+			*j = matches[c.Rand.Intn(len(matches))]
+		},
 		func(j *metav1.ListMeta, c fuzz.Continue) {
 			j.ResourceVersion = strconv.FormatUint(c.RandUint64(), 10)
 			j.SelfLink = c.RandString()

staging/src/k8s.io/api/testdata/HEAD/core.v1.ListOptions.yaml

@@ -36,6 +36,7 @@ filegroup(
     srcs = [
         ":package-srcs",
         "//staging/src/k8s.io/apimachinery/pkg/apis/meta/internalversion/scheme:all-srcs",
+        "//staging/src/k8s.io/apimachinery/pkg/apis/meta/internalversion/validation:all-srcs",
     ],
     tags = ["automanaged"],
 )