Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for setResourceVersion (0.36 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top