Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for UpdatePodStatus (0.3 sec)

  1. pkg/kubelet/prober/testing/fake_manager.go

    func (FakeManager) CleanupPods(_ map[types.UID]sets.Empty) {}
    
    // Start simulates start syncing the probe status
    func (FakeManager) Start() {}
    
    // UpdatePodStatus simulates updating the Pod Status.
    func (FakeManager) UpdatePodStatus(_ *v1.Pod, podStatus *v1.PodStatus) {
    	for i := range podStatus.ContainerStatuses {
    		podStatus.ContainerStatuses[i].Ready = true
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 07 22:26:12 UTC 2023
    - 1.4K bytes
    - Viewed (0)
  2. pkg/kubelet/prober/prober_manager.go

    	// It takes a map of "desired pods" which should not be cleaned up.
    	CleanupPods(desiredPods map[types.UID]sets.Empty)
    
    	// UpdatePodStatus modifies the given PodStatus with the appropriate Ready state for each
    	// container based on container running status, cached probe results and worker states.
    	UpdatePodStatus(*v1.Pod, *v1.PodStatus)
    }
    
    type manager struct {
    	// Map of active workers for probes
    	workers map[probeKey]*worker
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 07 22:26:12 UTC 2023
    - 11K bytes
    - Viewed (0)
  3. pkg/kubelet/prober/prober_manager_test.go

    	m.startupManager.Set(kubecontainer.ParseContainerID(startedNoReadiness.ContainerID), results.Success, &v1.Pod{})
    	m.readinessManager.Set(kubecontainer.ParseContainerID(terminated.ContainerID), results.Success, &v1.Pod{})
    
    	m.UpdatePodStatus(&v1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			UID: testPodUID,
    		},
    		Spec: v1.PodSpec{
    			Containers: []v1.Container{
    				{Name: unprobed.Name},
    				{Name: probedReady.Name},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 18.8K bytes
    - Viewed (0)
  4. pkg/kubelet/kubelet_pods.go

    			// Force back to phase from the API server
    			s.Phase = pod.Status.Phase
    		}
    	}
    
    	// ensure the probe managers have up to date status for containers
    	kl.probeManager.UpdatePodStatus(pod, s)
    
    	// preserve all conditions not owned by the kubelet
    	s.Conditions = make([]v1.PodCondition, 0, len(pod.Status.Conditions)+1)
    	for _, c := range pod.Status.Conditions {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
Back to top