Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 30 for controllerRef (0.17 sec)

  1. 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
    			typeMetadata.Kind = controllerRef.Kind
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 05:10:23 UTC 2024
    - 18.6K bytes
    - Viewed (0)
  2. pkg/controller/job/job_controller.go

    	// Make sure the pod is still orphaned.
    	if controllerRef := metav1.GetControllerOf(sharedPod); controllerRef != nil {
    		if controllerRef.Kind != controllerKind.Kind || controllerRef.APIVersion != batch.SchemeGroupVersion.String() {
    			// The pod is controlled by an owner that is not a batch/v1 Job. Do not remove finalizer.
    			return nil
    		}
    		job := jm.resolveControllerRef(sharedPod.Namespace, controllerRef)
    		if job != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Jun 10 23:56:37 UTC 2024
    - 77.6K bytes
    - Viewed (0)
  3. pkg/controller/cronjob/cronjob_controllerv2_test.go

    					}
    					if got, want := controllerRef.Name, cj.Name; got != want {
    						t.Errorf("%s: controllerRef.Name = %q, want %q", name, got, want)
    					}
    					if got, want := controllerRef.UID, cj.UID; got != want {
    						t.Errorf("%s: controllerRef.UID = %q, want %q", name, got, want)
    					}
    					if controllerRef.Controller == nil || *controllerRef.Controller != true {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 70.8K bytes
    - Viewed (0)
  4. pkg/controller/statefulset/stateful_set_utils_test.go

    	set := newStatefulSet(1)
    	pod := newStatefulSetPod(set, 0)
    	controllerRef := metav1.GetControllerOf(pod)
    	if controllerRef == nil {
    		t.Fatalf("No ControllerRef found on new pod")
    	}
    	if got, want := controllerRef.APIVersion, apps.SchemeGroupVersion.String(); got != want {
    		t.Errorf("controllerRef.APIVersion = %q, want %q", got, want)
    	}
    	if got, want := controllerRef.Kind, "StatefulSet"; got != want {
    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/controller/deployment/util/deployment_util.go

    // ListReplicaSets returns a slice of RSes the given deployment targets.
    // Note that this does NOT attempt to reconcile ControllerRef (adopt/orphan),
    // because only the controller itself should do that.
    // However, it does filter out anything whose ControllerRef doesn't match.
    func ListReplicaSets(deployment *apps.Deployment, getRSList RsListFunc) ([]*apps.ReplicaSet, error) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 07:09:11 UTC 2023
    - 39.3K bytes
    - Viewed (0)
  6. pkg/controller/deployment/deployment_controller_test.go

    	// Add a Pod for each ReplicaSet.
    	pod1 := generatePodFromRS(rs1)
    	pod2 := generatePodFromRS(rs2)
    	// Add a Pod that has matching labels, but no ControllerRef.
    	pod3 := generatePodFromRS(rs1)
    	pod3.Name = "pod3"
    	pod3.OwnerReferences = nil
    	// Add a Pod that has matching labels and ControllerRef, but is inactive.
    	pod4 := generatePodFromRS(rs1)
    	pod4.Name = "pod4"
    	pod4.Status.Phase = v1.PodFailed
    
    	f.dLister = append(f.dLister, d)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 32.5K bytes
    - Viewed (0)
  7. pkg/controller/history/controller_history.go

    	if len(prefix) > 223 {
    		prefix = prefix[:223]
    	}
    
    	return fmt.Sprintf("%s-%s", prefix, hash)
    }
    
    // NewControllerRevision returns a ControllerRevision with a ControllerRef pointing to parent and indicating that
    // parent is of parentKind. The ControllerRevision has labels matching template labels, contains Data equal to data, and
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Nov 05 13:33:52 UTC 2021
    - 18.2K bytes
    - Viewed (0)
  8. pkg/controller/replication/conversion.go

    func (pc podControlAdapter) CreatePods(ctx context.Context, namespace string, template *v1.PodTemplateSpec, object runtime.Object, controllerRef *metav1.OwnerReference) error {
    	rc, err := convertRStoRC(object.(*apps.ReplicaSet))
    	if err != nil {
    		return err
    	}
    	return pc.PodControlInterface.CreatePods(ctx, namespace, template, rc, controllerRef)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Dec 14 18:43:33 UTC 2022
    - 12.7K bytes
    - Viewed (0)
  9. pkg/controller/deployment/sync.go

    		// Otherwise, this is a hash collision and we need to increment the collisionCount field in
    		// the status of the Deployment and requeue to try the creation in the next sync.
    		controllerRef := metav1.GetControllerOf(rs)
    		if controllerRef != nil && controllerRef.UID == d.UID && deploymentutil.EqualIgnoreHash(&d.Spec.Template, &rs.Spec.Template) {
    			createdRS = rs
    			err = nil
    			break
    		}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jul 05 23:39:52 UTC 2023
    - 24.5K bytes
    - Viewed (0)
  10. pkg/controller/replicaset/replica_set_test.go

    	isController := true
    	controllerRef1 := metav1.OwnerReference{UID: testRSSpec1.UID, APIVersion: "v1", Kind: "ReplicaSet", Name: testRSSpec1.Name, Controller: &isController}
    	controllerRef2 := metav1.OwnerReference{UID: testRSSpec2.UID, APIVersion: "v1", Kind: "ReplicaSet", Name: testRSSpec2.Name, Controller: &isController}
    
    	// case 1: Pod with a ControllerRef
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 69.2K bytes
    - Viewed (0)
Back to top