- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for podsToDelete (0.2 sec)
-
pkg/controller/daemon/daemon_controller.go
podsToDelete = append(podsToDelete, oldestOldPod.Name) } } case !shouldContinueRunning && exists: // If daemon pod isn't supposed to run on node, but it is, delete all daemon pods on node. for _, pod := range daemonPods { if pod.DeletionTimestamp != nil { continue } podsToDelete = append(podsToDelete, pod.Name) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 51.3K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set_test.go
if related == nil { related = test.pods } podsToDelete := getPodsToDelete(test.pods, related, test.diff) if len(podsToDelete) != len(test.expectedPodsToDelete) { t.Errorf("%s: unexpected pods to delete, expected %v, got %v", test.name, test.expectedPodsToDelete, podsToDelete) } if !reflect.DeepEqual(podsToDelete, test.expectedPodsToDelete) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 69.2K bytes - Viewed (0) -
pkg/controller/job/job_controller.go
if rmAtLeast < 0 { rmAtLeast = 0 } podsToDelete := activePodsForRemoval(job, jobCtx.activePods, int(rmAtLeast)) if len(podsToDelete) > MaxPodCreateDeletePerSync { podsToDelete = podsToDelete[:MaxPodCreateDeletePerSync] } if len(podsToDelete) > 0 { jm.expectations.ExpectDeletions(logger, jobKey, len(podsToDelete))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 23:56:37 UTC 2024 - 77.6K bytes - Viewed (0) -
pkg/controller/replicaset/replica_set.go
// expired even if other pods are deleted. rsc.expectations.ExpectDeletions(logger, rsKey, getPodKeys(podsToDelete)) errCh := make(chan error, diff) var wg sync.WaitGroup wg.Add(diff) for _, pod := range podsToDelete { go func(targetPod *v1.Pod) { defer wg.Done() if err := rsc.podControl.DeletePod(ctx, rs.Namespace, targetPod.Name, rs); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 33.2K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_set_control.go
} // Now we need to delete MaxUnavailable- unavailablePods // start deleting one by one starting from the highest ordinal first podsToDelete := maxUnavailable - unavailablePods deletedPods := 0 for target := len(replicas) - 1; target >= updateMin && deletedPods < podsToDelete; target-- { // delete the Pod if it is healthy and the revision doesnt match the target
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 18 08:03:46 UTC 2024 - 30.9K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue_test.go
podsToAdd []*v1.Pod expectedMapAfterAdd map[string]*framework.QueuedPodInfo podsToUpdate []*v1.Pod expectedMapAfterUpdate map[string]*framework.QueuedPodInfo podsToDelete []*v1.Pod expectedMapAfterDelete map[string]*framework.QueuedPodInfo }{ { name: "create, update, delete subset of pods", podsToAdd: []*v1.Pod{pods[0], pods[1], pods[2], pods[3]},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0)