Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ContainerStateRunning (0.22 sec)

  1. pkg/kubelet/runonce.go

    func (kl *Kubelet) isPodRunning(pod *v1.Pod, status *kubecontainer.PodStatus) bool {
    	for _, c := range pod.Spec.Containers {
    		cs := status.FindContainerStatusByName(c.Name)
    		if cs == nil || cs.State != kubecontainer.ContainerStateRunning {
    			klog.InfoS("Container not running", "pod", klog.KObj(pod), "containerName", c.Name)
    			return false
    		}
    	}
    	return true
    }
    
    // getFailedContainer returns failed container name for pod.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Aug 04 06:56:50 UTC 2023
    - 5.9K bytes
    - Viewed (0)
  2. pkg/kubelet/prober/common_test.go

    func getTestRunningStatusWithStarted(started bool) v1.PodStatus {
    	containerStatus := v1.ContainerStatus{
    		Name:        testContainerName,
    		ContainerID: testContainerID.String(),
    	}
    	containerStatus.State.Running = &v1.ContainerStateRunning{StartedAt: metav1.Now()}
    	containerStatus.Started = &started
    	podStatus := v1.PodStatus{
    		Phase:             v1.PodRunning,
    		ContainerStatuses: []v1.ContainerStatus{containerStatus},
    	}
    	return podStatus
    }
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 12 16:57:26 UTC 2023
    - 4.3K bytes
    - Viewed (0)
  3. pkg/kubelet/pleg/evented_test.go

    			ID: types.UID(id),
    			SandboxStatuses: []*v1.PodSandboxStatus{
    				{Id: id},
    			},
    			ContainerStatuses: []*kubecontainer.Status{
    				{ID: kubecontainer.ContainerID{ID: id}, State: kubecontainer.ContainerStateRunning},
    			},
    		}
    
    		pleg.updateRunningPodMetric(podStatuses[i])
    		pleg.cache.Set(podStatuses[i].ID, podStatuses[i], nil, time.Now())
    
    	}
    	pleg.cache.UpdateTime(time.Now())
    
    	expectedMetric := `
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 01 07:45:05 UTC 2023
    - 6.4K bytes
    - Viewed (0)
  4. pkg/kubelet/runonce_test.go

    	// TODO(random-liu) Fix the test, make it meaningful.
    	fakeRuntime.PodStatus = kubecontainer.PodStatus{
    		ContainerStatuses: []*kubecontainer.Status{
    			{
    				Name:  "bar",
    				State: kubecontainer.ContainerStateRunning,
    			},
    		},
    	}
    	results, err := kb.runOnce(ctx, pods, time.Millisecond)
    	if err != nil {
    		t.Errorf("unexpected error: %v", err)
    	}
    	if results[0].Err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 06:59:54 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  5. pkg/kubelet/prober/scale_test.go

    						Name:        fmt.Sprintf("container%d", j),
    						ContainerID: fmt.Sprintf("pod%d://container%d", i, j),
    						State: v1.ContainerState{
    							Running: &v1.ContainerStateRunning{
    								StartedAt: metav1.Now(),
    							},
    						},
    						Started: utilpointer.Bool(true),
    					})
    				}
    				podManager.AddPod(&pod)
    				m.statusManager.SetPodStatus(&pod, pod.Status)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Aug 16 16:33:01 UTC 2023
    - 8.2K bytes
    - Viewed (0)
Back to top