Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 12 for GetOwnerReferences (0.42 sec)

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

    	}
    	return &cp
    }
    
    // GetControllerOfNoCopy returns a pointer to the controllerRef if controllee has a controller
    func GetControllerOfNoCopy(controllee Object) *OwnerReference {
    	refs := controllee.GetOwnerReferences()
    	for i := range refs {
    		if refs[i].Controller != nil && *refs[i].Controller {
    			return &refs[i]
    		}
    	}
    	return nil
    }
    
    // NewControllerRef creates an OwnerReference pointing to the given owner.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 09 05:14:33 UTC 2024
    - 2K bytes
    - Viewed (0)
  2. pkg/controller/statefulset/stateful_set_test.go

    					t.Errorf("bad claim ownerRefs: %s: %v", claim.Name, claim.GetOwnerReferences())
    				}
    			case scaledownPolicy == retain && deletionPolicy == delete:
    				if hasNamedOwnerRef(claim, podName) || !hasNamedOwnerRef(claim, set.Name) {
    					t.Errorf("bad claim ownerRefs: %s: %v", claim.Name, claim.GetOwnerReferences())
    				}
    			case scaledownPolicy == delete && deletionPolicy == retain:
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 33.1K bytes
    - Viewed (0)
  3. pkg/controller/statefulset/stateful_set_utils.go

    	if policy.WhenScaled == retain && policy.WhenDeleted == retain {
    		// On a retain policy, it's not a problem for different controller to be managing the claims.
    		return false
    	}
    	for _, ownerRef := range claim.GetOwnerReferences() {
    		if matchesRef(&ownerRef, set, controllerKind) {
    			if ownerRef.UID != set.GetUID() {
    				// A UID mismatch means that pods were incorrectly orphaned. Treating this as an unexpected
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 26.7K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  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. 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)
  9. 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)
  10. 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)
Back to top