Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 24 for setResourceVersion (0.77 sec)

  1. staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/unstructured/unstructured_test.go

    	// to check that omitempty fields having zero values are never set
    	u.SetName("")
    	u.SetGenerateName("")
    	u.SetNamespace("")
    	u.SetSelfLink("")
    	u.SetUID("")
    	u.SetResourceVersion("")
    	u.SetGeneration(0)
    	u.SetCreationTimestamp(metav1.Time{})
    	u.SetDeletionTimestamp(nil)
    	u.SetDeletionGracePeriodSeconds(nil)
    	u.SetLabels(nil)
    	u.SetAnnotations(nil)
    	u.SetOwnerReferences(nil)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:48:03 UTC 2023
    - 5K bytes
    - Viewed (0)
  2. pkg/registry/networking/networkpolicy/strategy_test.go

    	if len(errs) != 0 {
    		t.Errorf("Unexpected error from validation for created Network Policy: %v", errs)
    	}
    
    	updatedNetPol := makeNetworkPolicy(true, true, true)
    	updatedNetPol.ObjectMeta.SetResourceVersion("1")
    	Strategy.PrepareForUpdate(context.Background(), updatedNetPol, netPol)
    
    	errs = Strategy.ValidateUpdate(context.Background(), updatedNetPol, netPol)
    	if len(errs) != 0 {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon May 01 18:19:25 UTC 2023
    - 2.9K bytes
    - Viewed (0)
  3. operator/pkg/helmreconciler/apply_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)
    }}
    
    func TestHelmReconciler_ApplyObject(t *testing.T) {
    	tests := []struct {
    		name         string
    		currentState string
    		input        string
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Dec 12 17:12:54 UTC 2023
    - 4.9K bytes
    - Viewed (0)
  4. pkg/volume/util/resize_util_test.go

    		{
    			Type:               v1.PersistentVolumeClaimFileSystemResizePending,
    			Status:             v1.ConditionTrue,
    			LastTransitionTime: metav1.Now(),
    		},
    	}).get()
    	pvc1.SetResourceVersion("10")
    	pvc2 := pvc1.DeepCopy()
    	pvc2.Status.Capacity = v1.ResourceList{
    		v1.ResourceName("size"): resource.MustParse("10G"),
    	}
    	patchBytes, err := createPVCPatch(pvc1, pvc2, true /* addResourceVersionCheck */)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 9.5K 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/registry/rest/resttest/resttest.go

    	createdMeta := t.getObjectMetaOrFail(created)
    	createdFakeMeta := t.getObjectMetaOrFail(createdFake)
    	createdMeta.SetCreationTimestamp(createdFakeMeta.GetCreationTimestamp())
    	createdFakeMeta.SetResourceVersion("")
    	createdMeta.SetResourceVersion("")
    	createdMeta.SetUID(createdFakeMeta.GetUID())
    
    	if e, a := created, createdFake; !apiequality.Semantic.DeepEqual(e, a) {
    		t.Errorf("unexpected obj: %#v, expected %#v", e, a)
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jul 26 17:14:05 UTC 2022
    - 55.8K bytes
    - Viewed (0)
  7. staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/unstructured/unstructured_list.go

    	u.setNestedField(kind, "kind")
    }
    
    func (u *UnstructuredList) GetResourceVersion() string {
    	return getNestedString(u.Object, "metadata", "resourceVersion")
    }
    
    func (u *UnstructuredList) SetResourceVersion(version string) {
    	u.setNestedField(version, "metadata", "resourceVersion")
    }
    
    func (u *UnstructuredList) GetSelfLink() string {
    	return getNestedString(u.Object, "metadata", "selfLink")
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun May 28 04:46:35 UTC 2023
    - 6.3K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/helpers_test.go

    	// generateName doesn't do anything after create
    	existingMeta.SetGenerateName("")
    	// resourceVersion is enforced in validation and used during the storage update
    	existingMeta.SetResourceVersion("")
    	// fields made immutable in validation
    	existingMeta.SetUID(types.UID(""))
    	existingMeta.SetName("")
    	existingMeta.SetNamespace("")
    	existingMeta.SetCreationTimestamp(Time{})
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 12 15:46:12 UTC 2023
    - 7.1K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top