- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 15 for setResourceVersion (0.36 sec)
-
staging/src/k8s.io/apimachinery/pkg/test/api_meta_meta_test.go
} accessor.SetNamespace("baz") accessor.SetName("bar") accessor.SetGenerateName("generate") accessor.SetUID("other") typeAccessor.SetAPIVersion("c") typeAccessor.SetKind("d") accessor.SetResourceVersion("2") accessor.SetSelfLink("google.com") accessor.SetFinalizers([]string{"finalizer.3"}) // Prove that accessor changes the original object. if e, a := "baz", j.Namespace; e != a {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 14 10:11:56 UTC 2022 - 12.9K bytes - Viewed (0) -
staging/src/k8s.io/cli-runtime/pkg/resource/helper.go
return m.createResource(m.RESTClient, m.Resource, namespace, obj, options) } if version != "" { if err := metadataAccessor.SetResourceVersion(obj, ""); err != nil { return nil, err } } } return m.createResource(m.RESTClient, m.Resource, namespace, obj, options) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 26 03:45:13 UTC 2022 - 10.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/api/meta/meta.go
if err != nil { return "", err } return accessor.GetResourceVersion(), nil } func (resourceAccessor) SetResourceVersion(obj runtime.Object, version string) error { accessor, err := CommonAccessor(obj) if err != nil { return err } accessor.SetResourceVersion(version) return nil } func (resourceAccessor) Continue(obj runtime.Object) (string, error) { accessor, err := ListAccessor(obj)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jun 25 16:23:43 UTC 2022 - 16.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/test/apis_meta_v1_unstructed_unstructure_test.go
unstruct.SetKind("test_kind") unstruct.SetNamespace("test_namespace") unstruct.SetName("test_name") unstruct.SetGenerateName("test_generateName") unstruct.SetUID(types.UID("test_uid")) unstruct.SetResourceVersion("test_resourceVersion") unstruct.SetSelfLink("test_selfLink") unstruct.SetCreationTimestamp(metav1.Date(2009, time.November, 10, 23, 0, 0, 0, time.UTC)) date := metav1.Date(2010, time.November, 10, 23, 0, 0, 0, time.UTC)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 05 20:12:50 UTC 2022 - 17.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/caching_object.go
o.lock.RLock() defer o.lock.RUnlock() return o.object.GetResourceVersion() } func (o *cachingObject) SetResourceVersion(version string) { o.conditionalSet( func() bool { return o.object.GetResourceVersion() == version }, func() { o.object.SetResourceVersion(version) }, ) } func (o *cachingObject) GetGeneration() int64 { o.lock.RLock() defer o.lock.RUnlock()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 05 18:03:48 UTC 2023 - 12.6K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/admission/plugin/policy/generic/policy_test_context.go
} }) } func (p *PolicyTestContext[P, B, E]) updateOne(object runtime.Object) error { objectMeta, err := meta.Accessor(object) if err != nil { return err } objectMeta.SetResourceVersion(string(uuid.NewUUID())) objectGVK, gvr, err := p.inferGVK(object) if err != nil { return err } switch objectGVK { case p.policyGVK:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 06 00:00:21 UTC 2024 - 19K bytes - Viewed (0) -
pkg/volume/util/resize_util.go
} u := unstructured.Unstructured{Object: patchMap} a, err := meta.Accessor(&u) if err != nil { return nil, fmt.Errorf("error creating accessor: %v", err) } a.SetResourceVersion(resourceVersion) versionBytes, err := json.Marshal(patchMap) if err != nil { return nil, fmt.Errorf("error marshalling json patch: %v", err) } return versionBytes, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jul 17 19:30:35 UTC 2023 - 14.8K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/pkg/registry/customresource/etcd.go
return nil, err } if len(scale.ResourceVersion) != 0 { // The client provided a resourceVersion precondition. // Set that precondition and return any conflict errors to the client. cr.SetResourceVersion(scale.ResourceVersion) } updatedEntries, err := managedFieldsHandler.ToParent(scale.ManagedFields) if err != nil { return nil, err } cr.SetManagedFields(updatedEntries) return cr, nil
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 08 21:44:00 UTC 2023 - 12.4K bytes - Viewed (0) -
operator/cmd/mesh/manifest_shared_test.go
if err := clnt.Create(ctx, check); err != nil { return fmt.Errorf("could not inject object creation for fake: %w", err) } } else if err != nil { return err } obj.SetResourceVersion(check.GetResourceVersion()) return clnt.Update(ctx, obj) }} // recreateSimpleTestEnv mocks fake kube api server which relies on a simple object tracker func recreateSimpleTestEnv() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Feb 20 22:39:28 UTC 2024 - 11.7K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/unstructured/unstructured.go
} u.setNestedField(string(uid), "metadata", "uid") } func (u *Unstructured) GetResourceVersion() string { return getNestedString(u.Object, "metadata", "resourceVersion") } func (u *Unstructured) SetResourceVersion(resourceVersion string) { if len(resourceVersion) == 0 { RemoveNestedField(u.Object, "metadata", "resourceVersion") return } u.setNestedField(resourceVersion, "metadata", "resourceVersion") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun May 28 03:26:35 UTC 2023 - 13.7K bytes - Viewed (0)