- Sort Score
- Result 10 results
- Languages All
Results 21 - 30 of 32 for setResourceVersion (0.34 sec)
-
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) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/cacher_whitebox_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 10:12:02 UTC 2024 - 82.9K bytes - Viewed (0) -
pkg/apis/networking/validation/validation_test.go
t.Fatalf("Expected error: %v, got %v", testCase.expectedErrs[i].Error(), err.Error()) } } }) } } func TestValidateIngressClassUpdate(t *testing.T) { setResourceVersion := func(version string) netIngressTweak { return func(ingressClass *networking.IngressClass) { ingressClass.ObjectMeta.ResourceVersion = version } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:06 UTC 2023 - 73.3K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go
if obj.GetResourceVersion() != "" { return true, nil, errors.New("ResourceVersion must not be set on create") } obj.SetUID(types.UID(fmt.Sprintf("UID-%d", uidCounter))) uidCounter++ obj.SetResourceVersion(fmt.Sprintf("%d", resourceVersionCounter)) resourceVersionCounter++ case "update": uid := obj.GetUID() resourceVersion := obj.GetResourceVersion() if uid == "" {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 07:57:10 UTC 2024 - 61.9K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/runtime/interfaces.go
} // ResourceVersioner provides methods for setting and retrieving // the resource version from an API object. type ResourceVersioner interface { SetResourceVersion(obj Object, version string) error ResourceVersion(obj Object) (string, error) } // Namer provides methods for retrieving name and namespace of an API object. type Namer interface {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun May 28 03:26:35 UTC 2023 - 19K bytes - Viewed (0) -
pilot/pkg/config/kube/gateway/deploymentcontroller.go
if !canManage { log.Debugf("skipping %v/%v/%v, already managed", gvr, us.GetName(), us.GetNamespace()) return nil } // Ensure our canManage assertion is not stale us.SetResourceVersion(resourceVersion) log.Debugf("applying %v", string(j)) if err := d.patcher(gvr, us.GetName(), us.GetNamespace(), j); err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon May 13 21:43:20 UTC 2024 - 26.3K bytes - Viewed (0) -
pkg/controller/deployment/deployment_controller_test.go
b.Errorf("Invalid map size, expected 2, got: %d", len(m)) } } } func bumpResourceVersion(obj metav1.Object) { ver, _ := strconv.ParseInt(obj.GetResourceVersion(), 10, 32) obj.SetResourceVersion(strconv.FormatInt(ver+1, 10)) } // generatePodFromRS creates a pod, with the input ReplicaSet's selector and its template func generatePodFromRS(rs *apps.ReplicaSet) *v1.Pod { trueVar := true
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 32.5K bytes - Viewed (0) -
staging/src/k8s.io/apimachinery/pkg/util/managedfields/fieldmanager_test.go
"apiVersion": "apps/v1", "kind": "Deployment", }, } newObj.SetName("b") newObj.SetNamespace("b") newObj.SetUID("b") newObj.SetGeneration(0) newObj.SetResourceVersion("b") newObj.SetCreationTimestamp(metav1.NewTime(time.Now())) newObj.SetManagedFields([]metav1.ManagedFieldsEntry{ { Manager: "update", Operation: metav1.ManagedFieldsOperationApply,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 16 20:03:48 UTC 2023 - 32.5K bytes - Viewed (0) -
staging/src/k8s.io/apiextensions-apiserver/test/integration/conversion/conversion_test.go
APIVersion: "v1", Kind: "Namespace", Name: "default", UID: "1234", Controller: nil, BlockOwnerDeletion: nil, }}) u.SetResourceVersion("42") u.SetFinalizers([]string{"foo"}) if err := unstructured.SetNestedField(u.Object, "foo", "metadata", "garbage"); err != nil { return runtime.RawExtension{}, err } raw, err := json.Marshal(u)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 06 05:32:34 UTC 2023 - 47.1K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control_test.go
obj, isObj := object.(metav1.Object) if !isObj { return } if version := obj.GetResourceVersion(); version == "" { obj.SetResourceVersion("1") } else if intValue, err := strconv.ParseInt(version, 10, 32); err == nil { obj.SetResourceVersion(strconv.FormatInt(intValue+1, 10)) } } func TestParallelScale(t *testing.T) { for _, tc := range []struct { desc string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 07 19:01:47 UTC 2024 - 108.7K bytes - Viewed (0)