- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for NewPodControllerRefManager (0.48 sec)
-
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) -
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)