- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for ResourceVersionMatchNotOlderThan (0.33 sec)
-
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/request/list_work_estimator.go
hasLimit := opts.Limit > 0 && resourceVersion != "0" // Watch cache only supports ResourceVersionMatchNotOlderThan (default). unsupportedMatch := match != "" && match != metav1.ResourceVersionMatchNotOlderThan return consistentReadFromStorage || hasContinuation || hasLimit || unsupportedMatch
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go
t.Fatalf("failed to list objects: %v", err) } expectNoDiff(t, "incorrect lists", result1, result2) // Now also verify the ResourceVersionMatchNotOlderThan. options.ResourceVersionMatch = metav1.ResourceVersionMatchNotOlderThan result3 := example.PodList{} if err := store.GetList(ctx, "/pods", options, &result3); err != nil { t.Fatalf("failed to list objects: %v", err) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 91.4K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/reconcilers/peer_endpoint_lease.go
func (r *peerEndpointLeaseReconciler) ListLeases() ([]string, error) { storageOpts := storage.ListOptions{ ResourceVersion: "0", ResourceVersionMatch: metav1.ResourceVersionMatchNotOlderThan, Predicate: storage.Everything, Recursive: true, } ipInfoList, err := r.getIpInfoList(storageOpts) if err != nil { return nil, err }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 12.3K bytes - Viewed (0) -
pkg/controlplane/reconcilers/lease.go
func (s *storageLeases) ListLeases() ([]string, error) { ipInfoList := &corev1.EndpointsList{} storageOpts := storage.ListOptions{ ResourceVersion: "0", ResourceVersionMatch: metav1.ResourceVersionMatchNotOlderThan, Predicate: storage.Everything, Recursive: true, } if err := s.storage.GetList(apirequest.NewDefaultContext(), s.baseKey, storageOpts, ipInfoList); err != nil { return nil, err
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Aug 24 09:23:05 UTC 2023 - 11.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store_test.go
rv: "", expectedRev: 0, }, { name: "default", expectedRev: 0, }, { name: "rev resolve to 0 if ResourceVersionMatchNotOlderThan", rv: "200", rvMatch: metav1.ResourceVersionMatchNotOlderThan, expectedRev: 0, }, { name: "specified rev if ResourceVersionMatchExact", rv: "200",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 12:45:33 UTC 2024 - 26.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/fuzzer/fuzzer.go
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() },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 03 15:12:26 UTC 2024 - 9.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher.go
hasLimit := pred.Limit > 0 && resourceVersion != "0" // Watch cache only supports ResourceVersionMatchNotOlderThan (default). unsupportedMatch := match != "" && match != metav1.ResourceVersionMatchNotOlderThan return consistentReadFromStorage || hasContinuation || hasLimit || unsupportedMatch }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 51.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/store.go
if err != nil { return withRev, apierrors.NewBadRequest(fmt.Sprintf("invalid resource version: %v", err)) } switch opts.ResourceVersionMatch { case metav1.ResourceVersionMatchNotOlderThan: // The not older than constraint is checked after we get a response from etcd, // and returnedRV is then set to the revision we get from the etcd response. case metav1.ResourceVersionMatchExact:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 10 11:56:42 UTC 2024 - 35.2K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/types.go
// // See https://kubernetes.io/docs/reference/using-api/api-concepts/#resource-versions for // details. type ResourceVersionMatch string const ( // ResourceVersionMatchNotOlderThan matches data at least as new as the provided // resourceVersion. ResourceVersionMatchNotOlderThan ResourceVersionMatch = "NotOlderThan" // ResourceVersionMatchExact matches data at the exact resourceVersion // provided.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 10:52:25 UTC 2024 - 79.2K bytes - Viewed (1)