Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for IsStaticPod (0.26 sec)

  1. pkg/kubelet/types/pod_update_test.go

    			expected: false,
    		},
    	}
    
    	for _, test := range tests {
    		t.Run(test.name, func(t *testing.T) {
    			isStaticPod := IsStaticPod(test.pod)
    			assert.Equal(t, test.expected, isStaticPod)
    		})
    	}
    }
    
    func TestIsCriticalPod(t *testing.T) {
    	tests := []struct {
    		name     string
    		pod      *v1.Pod
    		expected bool
    	}{
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Apr 21 08:20:50 UTC 2023
    - 10.4K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top