- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for terminatingPod (0.22 sec)
-
pkg/kubelet/kubelet_pods.go
for uid, sync := range workingPods { switch sync.State { case SyncPod: runningPods[uid] = struct{}{} possiblyRunningPods[uid] = struct{}{} case TerminatingPod: possiblyRunningPods[uid] = struct{}{} default: } } // Retrieve the list of running containers from the runtime to perform cleanup.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0) -
pkg/kubelet/pod_workers_test.go
state = podWorkers.SyncKnownPods([]*v1.Pod{ newNamedPod("8-static", "test1", "pod1", true), }) drainAllWorkers(podWorkers) if e, a := map[types.UID]PodWorkerSync{ "1-normal": {State: TerminatingPod, Orphan: true, HasConfig: true}, "8-static": {State: SyncPod, HasConfig: true, Static: true}, }, state; !reflect.DeepEqual(e, a) { t.Fatalf("unexpected actual restartable: %s", cmp.Diff(e, a)) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 75.6K bytes - Viewed (0) -
pkg/controller/job/job_controller_test.go
pods = append(pods, newPod) } return pods } func setPodsStatuses(podIndexer cache.Indexer, job *batch.Job, pendingPods, activePods, succeededPods, failedPods, terminatingPods, readyPods int) { for _, pod := range newPodList(pendingPods, v1.PodPending, job) { podIndexer.Add(pod) } running := newPodList(activePods, v1.PodRunning, job) for i, p := range running {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 15:36:36 UTC 2024 - 229.2K bytes - Viewed (0)