- Sort Score
- Result 10 results
- Languages All
Results 1 - 5 of 5 for IsStaticPod (0.14 sec)
-
pkg/kubelet/lifecycle/predicate.go
}) } else { reasons = append(reasons, &PredicateFailureError{r.Name, r.Reason}) } } // Check taint/toleration except for static pods if !types.IsStaticPod(pod) { _, isUntolerated := corev1.FindMatchingUntoleratedTaint(nodeInfo.Node().Spec.Taints, pod.Spec.Tolerations, func(t *v1.Taint) bool { // Kubelet is only interested in the NoExecute taint.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 19 00:47:50 UTC 2023 - 10.9K bytes - Viewed (0) -
pkg/kubelet/status/status_manager.go
ExitCode: 137, }, } } // Make sure all pods are transitioned to a terminal phase. // TODO(#116484): Also assign terminal phase to static an pods. if !kubetypes.IsStaticPod(pod) { switch status.Phase { case v1.PodSucceeded, v1.PodFailed: // do nothing, already terminal case v1.PodPending, v1.PodRunning: if status.Phase == v1.PodRunning && isCached {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 02 16:27:19 UTC 2024 - 44.3K bytes - Viewed (0) -
pkg/kubelet/pod/pod_manager.go
mirrorToPod = make(map[kubetypes.MirrorPodUID]kubetypes.ResolvedPodUID, len(pm.translationByUID)) // Insert empty translation mapping for all static pods. for uid, pod := range pm.podByUID { if !kubetypes.IsStaticPod(pod) { continue } podToMirror[uid] = "" } // Fill in translations. Notice that if there is no mirror pod for a // static pod, its uid will be translated into empty string "". This
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 06:06:00 UTC 2024 - 11.9K bytes - Viewed (0) -
pkg/kubelet/config/config.go
if ref.Annotations == nil { ref.Annotations = make(map[string]string) } ref.Annotations[kubetypes.ConfigSourceAnnotationKey] = source // ignore static pods if !kubetypes.IsStaticPod(ref) { s.startupSLIObserver.ObservedPodOnWatch(ref, time.Now()) } if existing, found := oldPods[ref.UID]; found { pods[ref.UID] = existing
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 16.7K bytes - Viewed (0) -
pkg/kubelet/kubelet_getters.go
pods := kl.podManager.GetPods() // a kubelet running without apiserver requires an additional // update of the static pod status. See #57106 for i, p := range pods { if kubelettypes.IsStaticPod(p) { if status, ok := kl.statusManager.GetPodStatus(p.UID); ok { klog.V(2).InfoS("Pod status updated", "pod", klog.KObj(p), "status", status.Phase) // do not mutate the cache p = p.DeepCopy()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 09 00:48:07 UTC 2024 - 17.9K bytes - Viewed (0)