Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 25 for GetOwnerReferences (0.24 sec)

  1. pkg/controller/garbagecollector/patch.go

    	if err != nil {
    		return nil, err
    	}
    	expectedObjectMeta := ObjectMetaForPatch{}
    	expectedObjectMeta.ResourceVersion = accessor.GetResourceVersion()
    	refs := accessor.GetOwnerReferences()
    	for _, ref := range refs {
    		var skip bool
    		for _, ownerUID := range ownerUIDs {
    			if ref.UID == ownerUID {
    				skip = true
    				break
    			}
    		}
    		if !skip {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 05 13:33:52 UTC 2021
    - 5.6K bytes
    - Viewed (0)
  2. pkg/controller/statefulset/stateful_set_utils_test.go

    		claim.SetOwnerReferences(tc.originalRefs)
    		updateClaimOwnerRefForSetAndPod(logger, &claim, &set, &pod)
    		if ownerRefsChanged(tc.expectedRefs, claim.GetOwnerReferences()) {
    			t.Errorf("%s: expected %v, got %v", tc.name, tc.expectedRefs, claim.GetOwnerReferences())
    		}
    	}
    }
    
    func TestHasOwnerRef(t *testing.T) {
    	target := v1.Pod{}
    	target.SetOwnerReferences([]metav1.OwnerReference{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 50.9K bytes
    - Viewed (0)
  3. staging/src/k8s.io/apimachinery/pkg/api/meta/meta.go

    				DeletionGracePeriodSeconds: m.GetDeletionGracePeriodSeconds(),
    				Labels:                     m.GetLabels(),
    				Annotations:                m.GetAnnotations(),
    				OwnerReferences:            m.GetOwnerReferences(),
    				Finalizers:                 m.GetFinalizers(),
    				ManagedFields:              m.GetManagedFields(),
    			},
    		}
    	}
    }
    
    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. pkg/kube/controllers/common.go

    func EnqueueForParentHandler(q Queue, kind config.GroupVersionKind) func(obj Object) {
    	handler := func(obj Object) {
    		for _, ref := range obj.GetOwnerReferences() {
    			refGV, err := schema.ParseGroupVersion(ref.APIVersion)
    			if err != nil {
    				log.Errorf("could not parse OwnerReference api version %q: %v", ref.APIVersion, err)
    				continue
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Apr 11 08:27:29 UTC 2024
    - 8.9K bytes
    - Viewed (0)
  5. pkg/controller/garbagecollector/graph_builder.go

    		if len(added) != 0 || len(removed) != 0 || len(changed) != 0 {
    			// check if the changed dependency graph unblock owners that are
    			// waiting for the deletion of their dependents.
    			gb.addUnblockedOwnersToDeleteQueue(logger, removed, changed)
    			// update the node itself
    			existingNode.owners = accessor.GetOwnerReferences()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 36.9K bytes
    - Viewed (0)
  6. staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/helpers.go

    	meta.SetLabels(existingMeta.GetLabels())
    	meta.SetAnnotations(existingMeta.GetAnnotations())
    	meta.SetFinalizers(existingMeta.GetFinalizers())
    	meta.SetOwnerReferences(existingMeta.GetOwnerReferences())
    	// managedFields must be preserved since it's been modified to
    	// track changed fields in the status update.
    	//meta.SetManagedFields(existingMeta.GetManagedFields())
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Sep 15 10:58:36 UTC 2022
    - 9.6K bytes
    - Viewed (0)
  7. pkg/controller/statefulset/stateful_set_control_test.go

    		if err != nil {
    			t.Fatalf("%s: %s", test.name, err)
    		}
    		for _, claim := range claims {
    			for _, ref := range claim.GetOwnerReferences() {
    				if strings.HasPrefix(ref.Name, "foo-") {
    					t.Fatalf("Unexpected pod reference on %s: %v", claim.Name, claim.GetOwnerReferences())
    				}
    			}
    		}
    
    		replicas := *set.Spec.Replicas
    		*set.Spec.Replicas = 0
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 07 19:01:47 UTC 2024
    - 108.7K bytes
    - Viewed (0)
  8. staging/src/k8s.io/apimachinery/pkg/apis/meta/v1/unstructured/unstructured.go

    	if u.Object == nil {
    		u.Object = make(map[string]interface{})
    	}
    	SetNestedStringMap(u.Object, value, fields...)
    }
    
    func (u *Unstructured) GetOwnerReferences() []metav1.OwnerReference {
    	field, found, err := NestedFieldNoCopy(u.Object, "metadata", "ownerReferences")
    	if !found || err != nil {
    		return nil
    	}
    	original, ok := field.([]interface{})
    	if !ok {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun May 28 03:26:35 UTC 2023
    - 13.7K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apimachinery/pkg/test/api_meta_meta_test.go

    }
    
    func testGetOwnerReferences(t *testing.T) {
    	obj, expected := getObjectMetaAndOwnerReferences()
    	accessor, err := meta.Accessor(&obj)
    	if err != nil {
    		t.Error(err)
    	}
    	references := accessor.GetOwnerReferences()
    	if !reflect.DeepEqual(references, expected) {
    		t.Errorf("expect %#v\n got %#v", expected, references)
    	}
    }
    
    func testSetOwnerReferences(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 14 10:11:56 UTC 2022
    - 12.9K bytes
    - Viewed (0)
  10. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest.go

    	accessor, err := meta.Accessor(obj)
    	if err != nil {
    		// The object doesn't have metadata. Nothing we need to do here.
    		return
    	}
    	refs := accessor.GetOwnerReferences()
    	deduped, duplicates := dedupOwnerReferences(refs)
    	if len(duplicates) > 0 {
    		// NOTE: For CREATE and UPDATE requests the API server dedups both before and after mutating admission.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Mar 08 21:44:00 UTC 2023
    - 17K bytes
    - Viewed (0)
Back to top