Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 170 for pidStatus (0.21 sec)

  1. pkg/kubelet/runonce_test.go

    	podManager.SetPods(pods)
    	// The original test here is totally meaningless, because fakeruntime will always return an empty podStatus. While
    	// the original logic of isPodRunning happens to return true when podstatus is empty, so the test can always pass.
    	// Now the logic in isPodRunning is changed, to let the test pass, we set the podstatus directly in fake runtime.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 18 06:59:54 UTC 2024
    - 6.5K bytes
    - Viewed (0)
  2. pkg/client/conditions/conditions_test.go

    				Type: watch.Added,
    				Object: &corev1.Pod{
    					Status: corev1.PodStatus{
    						Phase: corev1.PodRunning,
    					},
    				},
    			},
    			want:    true,
    			wantErr: false,
    		},
    		{
    			name: "Pod Status is PodFailed",
    			event: watch.Event{
    				Type: watch.Added,
    				Object: &corev1.Pod{
    					Status: corev1.PodStatus{
    						Phase: corev1.PodFailed,
    					},
    				},
    			},
    			want:    false,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 12 02:48:46 UTC 2023
    - 3.1K bytes
    - Viewed (0)
  3. pkg/controller/job/backoff_utils_test.go

    			newFailedPods := []*v1.Pod{}
    
    			for _, finishTime := range tc.newSucceededPods {
    				newSucceededPods = append(newSucceededPods, &v1.Pod{
    					ObjectMeta: metav1.ObjectMeta{},
    					Status: v1.PodStatus{
    						Phase: v1.PodSucceeded,
    						ContainerStatuses: []v1.ContainerStatus{
    							{
    								State: v1.ContainerState{
    									Terminated: &v1.ContainerStateTerminated{
    										FinishedAt: finishTime,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 07:46:41 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  4. pkg/kubelet/status/fake_status_manager.go

    }
    
    func (m *fakeManager) Start() {
    	klog.InfoS("Start()")
    	return
    }
    
    func (m *fakeManager) GetPodStatus(uid types.UID) (v1.PodStatus, bool) {
    	klog.InfoS("GetPodStatus()")
    	return v1.PodStatus{}, false
    }
    
    func (m *fakeManager) SetPodStatus(pod *v1.Pod, status v1.PodStatus) {
    	klog.InfoS("SetPodStatus()")
    	return
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Mar 07 05:59:34 UTC 2023
    - 2.7K bytes
    - Viewed (0)
  5. pilot/pkg/serviceregistry/kube/controller/pod_test.go

    	if err := f(nil,
    		&v1.Pod{ObjectMeta: pod1, Status: v1.PodStatus{Conditions: notReadyCondition, PodIP: ip, Phase: v1.PodPending}},
    		model.EventUpdate); err != nil {
    		t.Error(err)
    	}
    	if handled != 0 {
    		t.Errorf("notified workload handler %d times, want %d", handled, 0)
    	}
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 16 18:27:40 UTC 2024
    - 12.3K bytes
    - Viewed (0)
  6. pkg/kube/krt/index_test.go

    		})
    	}
    
    	SimplePods.Register(TrackerHandler[SimplePod](tt))
    
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "name",
    			Namespace: "namespace",
    		},
    		Status: corev1.PodStatus{PodIP: "1.2.3.4"},
    	}
    	pc.CreateOrUpdateStatus(pod)
    	tt.WaitUnordered("add/namespace/name")
    	assert.Equal(t, fetchSorted("1.2.3.4"), []SimplePod{{NewNamed(pod), Labeled{}, "1.2.3.4"}})
    
    	pod.Status.PodIP = "1.2.3.5"
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 09 19:55:53 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  7. pkg/kubelet/kubelet_test.go

    		},
    	}
    	pods := []*v1.Pod{pod}
    	kl.podManager.SetPods(pods)
    	podStatus := &kubecontainer.PodStatus{ID: pod.UID}
    	gracePeriodOverride := int64(0)
    	err := kl.SyncTerminatingPod(context.Background(), pod, podStatus, &gracePeriodOverride, func(podStatus *v1.PodStatus) {
    		podStatus.Phase = v1.PodFailed
    		podStatus.Reason = "reason"
    		podStatus.Message = "message"
    	})
    	require.NoError(t, err)
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  8. pkg/kubelet/pleg/generic.go

    	}
    
    	// When we use Generic PLEG only, the PodStatus is saved in the cache without
    	// any validation of the existing status against the current timestamp.
    	// This works well when there is only Generic PLEG setting the PodStatus in the cache however,
    	// if we have multiple entities, such as Evented PLEG, while trying to set the PodStatus in the
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 19.3K bytes
    - Viewed (0)
  9. pkg/kube/krt/collection_test.go

    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "name",
    			Namespace: "namespace",
    		},
    	}
    	pc.Create(pod)
    	assert.Equal(t, fetcherSorted(SimplePods)(), nil)
    
    	pod.Status = corev1.PodStatus{PodIP: "1.2.3.4"}
    	pc.UpdateStatus(pod)
    	assert.EventuallyEqual(t, fetcherSorted(SimplePods), []SimplePod{{NewNamed(pod), Labeled{}, "1.2.3.4"}})
    
    	pod.Status.PodIP = "1.2.3.5"
    	pc.UpdateStatus(pod)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sun Apr 28 04:22:19 UTC 2024
    - 14.6K bytes
    - Viewed (0)
  10. pkg/kubelet/prober/prober_manager_test.go

    		Name:        "terminated_container",
    		ContainerID: "test://terminated_container_id",
    		State: v1.ContainerState{
    			Terminated: &v1.ContainerStateTerminated{},
    		},
    	}
    	podStatus := v1.PodStatus{
    		Phase: v1.PodRunning,
    		ContainerStatuses: []v1.ContainerStatus{
    			unprobed, probedReady, probedPending, probedUnready, notStartedNoReadiness, startedNoReadiness, terminated,
    		},
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 18.8K bytes
    - Viewed (0)
Back to top