Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 19 of 19 for GetOwnerReferences (0.31 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. pilot/pkg/config/file/store.go

    			Labels:            m.GetLabels(),
    			Annotations:       m.GetAnnotations(),
    			ResourceVersion:   m.GetResourceVersion(),
    			CreationTimestamp: m.GetCreationTimestamp().Time,
    			OwnerReferences:   m.GetOwnerReferences(),
    			Generation:        m.GetGeneration(),
    			Domain:            domainSuffix,
    		},
    		Spec: mv2,
    	}
    }
    
    // BuildFieldPathMap builds the flat map for each field of the YAML resource
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Feb 02 17:36:47 UTC 2024
    - 18.2K bytes
    - Viewed (0)
  6. pkg/kube/util.go

    		var controllerRef metav1.OwnerReference
    		controllerFound := false
    		for _, ref := range pod.GetOwnerReferences() {
    			if ref.Controller != nil && *ref.Controller {
    				controllerRef = ref
    				controllerFound = true
    				break
    			}
    		}
    		if controllerFound {
    			typeMetadata.APIVersion = controllerRef.APIVersion
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 05:10:23 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  7. pkg/controller/statefulset/stateful_pod_control_test.go

    			t.Errorf("Unexpected missing PVCs")
    		}
    		for k := range claims {
    			claim := claims[k]
    			// This ownerRef should be removed in the update.
    			claim.SetOwnerReferences(addControllerRef(claim.GetOwnerReferences(), set, controllerKind))
    			claimIndexer.Add(&claim)
    		}
    		control := NewStatefulPodControl(fakeClient, podLister, claimLister, recorder)
    		if err := control.UpdateStatefulPod(ctx, set, pod); err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 35.5K bytes
    - Viewed (0)
  8. pkg/controller/garbagecollector/garbagecollector.go

    	if item.isDeletingDependents() {
    		return gc.processDeletingDependentsItem(logger, item)
    	}
    
    	// compute if we should delete the item
    	ownerReferences := latest.GetOwnerReferences()
    	if len(ownerReferences) == 0 {
    		logger.V(2).Info("item doesn't have an owner, continue on next item",
    			"item", item.identity,
    		)
    		return nil
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 32.9K bytes
    - Viewed (0)
  9. pkg/controller/garbagecollector/garbagecollector_test.go

    				{UID: "2", BlockOwnerDeletion: &falseVar},
    				{UID: "3"},
    			},
    		},
    	}
    	accessor, err := meta.Accessor(&original)
    	if err != nil {
    		t.Fatal(err)
    	}
    	n := node{
    		owners: accessor.GetOwnerReferences(),
    	}
    	patch, err := n.unblockOwnerReferencesStrategicMergePatch()
    	if err != nil {
    		t.Fatal(err)
    	}
    	patched, err := strategicpatch.StrategicMergePatch(originalData, patch, v1.Pod{})
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.6K bytes
    - Viewed (0)
Back to top