Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 32 for setResourceVersion (0.26 sec)

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