- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for podWorker (0.15 sec)
-
pkg/kubelet/kubelet.go
// tracked by the podWorkers. Components that need to know the actual consumed resources of the // node or are driven by podWorkers and the sync*Pod methods (status, volume, stats) should also // consult the podWorkers when reconciling. // // TODO: review all kubelet components that need the actual set of pods (vs the desired set)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 126.1K bytes - Viewed (0) -
pkg/kubelet/kubelet_test.go
if expect, actual := []types.UID(nil), kubelet.podWorkers.(*fakePodWorkers).triggeredDeletion; !reflect.DeepEqual(expect, actual) { t.Fatalf("expected %v kills, got %v", expect, actual) } ready = true kubelet.HandlePodRemoves(pods) time.Sleep(2 * time.Second) // Sources are ready. Remove unwanted pods.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 106.9K bytes - Viewed (0) -
pkg/kubelet/kubelet_pods.go
// if a pod is fully terminated by UID, it should be excluded from the // list of pods if kl.podWorkers.IsPodKnownTerminated(p.UID) { continue } // terminal pods are considered inactive UNLESS they are actively terminating if kl.isAdmittedPodTerminal(p) && !kl.podWorkers.IsPodTerminationRequested(p.UID) { continue } filteredPods = append(filteredPods, p) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 14 16:09:17 UTC 2024 - 101.2K bytes - Viewed (0)