Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for NewPodControllerRefManager (0.48 sec)

  1. pkg/controller/statefulset/stateful_set.go

    		return nil, err
    	}
    
    	filter := func(pod *v1.Pod) bool {
    		// Only claim if it matches our StatefulSet name. Otherwise release/ignore.
    		return isMemberOf(set, pod)
    	}
    
    	cm := controller.NewPodControllerRefManager(ssc.podControl, set, selector, controllerKind, ssc.canAdoptFunc(ctx, set))
    	return cm.ClaimPods(ctx, pods, filter)
    }
    
    // If any adoptions are attempted, we should first recheck for deletion with
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 05 19:06:41 UTC 2024
    - 18.5K bytes
    - Viewed (0)
  2. pkg/controller/job/job_controller.go

    		}
    		if fresh.UID != j.UID {
    			return nil, fmt.Errorf("original Job %v/%v is gone: got uid %v, wanted %v", j.Namespace, j.Name, fresh.UID, j.UID)
    		}
    		return fresh, nil
    	})
    	cm := controller.NewPodControllerRefManager(jm.podControl, j, selector, controllerKind, canAdoptFunc, batch.JobTrackingFinalizer)
    	// When adopting Pods, this operation adds an ownerRef and finalizers.
    	pods, err = cm.ClaimPods(ctx, pods)
    	if err != 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)
Back to top