- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 587 for resourceVersion (0.29 sec)
-
pkg/controller/storageversionmigrator/resourceversion.go
logger.V(4).Info("Migration has already succeeded or failed previously, skipping", "svm", name) return nil } if len(toBeProcessedSVM.Status.ResourceVersion) != 0 { logger.V(4).Info("Resource version is already set", "svm", name) return nil } exists, err := rv.resourceExists(gvr) if err != nil { return err } if !exists {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 8.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cache_watcher_test.go
ObjFields: fields.Set{"spec.nodeName": ""}, ResourceVersion: 2, }, { Type: watch.Modified, PrevObject: &v1.Pod{ObjectMeta: metav1.ObjectMeta{ResourceVersion: "2"}}, PrevObjFields: fields.Set{"spec.nodeName": ""}, Object: &v1.Pod{ObjectMeta: metav1.ObjectMeta{ResourceVersion: "3"}}, ObjFields: fields.Set{"spec.nodeName": "host"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 22.9K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache.go
} // SendInitialEvents = false and resourceVersion = 0 // means that the request would like to start watching // from Any resourceVersion resourceVersion = w.resourceVersion } if resourceVersion < oldest-1 { return nil, errors.NewResourceExpired(fmt.Sprintf("too old resource version: %d (%d)", resourceVersion, oldest-1)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 10:20:57 UTC 2024 - 26.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
} commonTestCases := []testCase{ {opts: storage.ListOptions{ResourceVersion: "0"}, expectBypass: false}, {opts: storage.ListOptions{ResourceVersion: "1"}, expectBypass: false}, {opts: storage.ListOptions{ResourceVersion: "", Predicate: storage.SelectionPredicate{Continue: "a"}}, expectBypass: true}, {opts: storage.ListOptions{ResourceVersion: "0", Predicate: storage.SelectionPredicate{Continue: "a"}}, expectBypass: true},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
pilot/pkg/config/kube/crdclient/types.gen.go
} } func delete(c kube.Client, typ config.GroupVersionKind, name, namespace string, resourceVersion *string) error { var deleteOptions metav1.DeleteOptions if resourceVersion != nil { deleteOptions.Preconditions = &metav1.Preconditions{ResourceVersion: resourceVersion} } switch typ { case gvk.AuthorizationPolicy:
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 17:37:32 UTC 2024 - 62.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/watcher_tests.go
t.Fatalf("Delete failed: %v", err) } // Verify that ResourceVersion has changed on deletion. if storedObj.ResourceVersion == deletedObj.ResourceVersion { t.Fatalf("ResourceVersion didn't changed on deletion: %s", deletedObj.ResourceVersion) } testCheckResult(t, w, watch.Event{Type: watch.Deleted, Object: deletedObj}) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 63.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/testing/store_tests.go
// We expect the resource version of the returned object to be // updated compared to the last existing object. if storedObj.ResourceVersion == out.ResourceVersion { t.Errorf("expecting resource version to be updated, but get: %s", out.ResourceVersion) } out.ResourceVersion = storedObj.ResourceVersion expectNoDiff(t, "incorrect pod:", tt.expectedObj, out) }) } }
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/interfaces.go
// object twice with the same data except for the ResourceVersion and SelfLink must be // a no-op. A resourceVersion of type uint64 is a 'raw' resourceVersion, // intended to be sent directly to or from the backend. A resourceVersion of // type string is a 'safe' resourceVersion, intended for consumption by users. type Versioner interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 07:53:48 UTC 2024 - 14.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresourcedefinition/strategy_test.go
crd := &apiextensions.CustomResourceDefinition{ ObjectMeta: metav1.ObjectMeta{Name: "foos." + test.group, Annotations: map[string]string{v1beta1.KubeAPIApprovedAnnotation: test.annotationValue}, ResourceVersion: "1"}, Spec: apiextensions.CustomResourceDefinitionSpec{ Group: test.group, Scope: apiextensions.NamespaceScoped, Version: "v1",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 44.6K bytes - Viewed (0) -
staging/src/k8s.io/api/testdata/HEAD/core.v1.Node.yaml
controller: true kind: kindValue name: nameValue uid: uidValue resourceVersion: resourceVersionValue selfLink: selfLinkValue uid: uidValue spec: configSource: configMap: kubeletConfigKey: kubeletConfigKeyValue name: nameValue namespace: namespaceValue resourceVersion: resourceVersionValue uid: uidValue externalID: externalIDValue podCIDR: podCIDRValue
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 13 23:06:39 UTC 2024 - 2.9K bytes - Viewed (0)