- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for resourceVersionNotOlderThan (0.27 sec)
-
staging/src/k8s.io/apiserver/pkg/storage/testing/utils.go
for i, v := range s { result[i] = v } return result } // resourceVersionNotOlderThan returns a function to validate resource versions. Resource versions // referring to points in logical time before the sentinel generate an error. All logical times as // new as the sentinel or newer generate no error. func resourceVersionNotOlderThan(sentinel string) func(string) error { return func(resourceVersion string) error {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 22 07:26:55 UTC 2024 - 10.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go
expectedRemainingItemCount: utilpointer.Int64(1), rv: list.ResourceVersion, rvMatch: metav1.ResourceVersionMatchNotOlderThan, expectRVFunc: resourceVersionNotOlderThan(list.ResourceVersion), }, { name: "test List with limit at resource version 0", prefix: "/pods/second/", pred: storage.SelectionPredicate{ Label: labels.Everything(),
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/storage/testing/watcher_tests.go
key := computePodKey(input) out := &example.Pod{} if err := store.Create(ctx, key, input, out, 0); err != nil { t.Fatalf("Create failed: %v", err) } validateResourceVersion := resourceVersionNotOlderThan(out.ResourceVersion) opts := storage.ListOptions{ ResourceVersion: out.ResourceVersion, Predicate: storage.Everything, ProgressNotify: true, } w, err := store.Watch(ctx, key, opts)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0)