Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 119 for pidStatus (0.14 sec)

  1. 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)
  2. 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)
  3. 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)
  4. pkg/kubelet/container/runtime.go

    	// not managed by kubelet.
    	Hash uint64
    	// State is the state of the container.
    	State State
    }
    
    // PodStatus represents the status of the pod and its containers.
    // v1.PodStatus can be derived from examining PodStatus and v1.Pod.
    type PodStatus struct {
    	// ID of the pod.
    	ID types.UID
    	// Name of the pod.
    	Name string
    	// Namespace of the pod.
    	Namespace string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 27.8K bytes
    - Viewed (0)
  5. pkg/kubelet/pod_workers_test.go

    	kl.pod, kl.mirrorPod, kl.podStatus = pod, mirrorPod, podStatus
    	kl.wg.Done()
    	return false, nil
    }
    
    func (kl *simpleFakeKubelet) SyncTerminatingPod(ctx context.Context, pod *v1.Pod, podStatus *kubecontainer.PodStatus, gracePeriod *int64, podStatusFn func(*v1.PodStatus)) error {
    	return nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 75.6K bytes
    - Viewed (0)
  6. pkg/kubelet/nodeshutdown/nodeshutdown_manager_linux_test.go

    		expectedError                    error
    		expectedPodStatuses              map[string]v1.PodStatus
    	}{
    		{
    			desc: "verify pod status; PodDisruptionConditions enabled",
    			activePods: []*v1.Pod{
    				{
    					ObjectMeta: metav1.ObjectMeta{Name: "running-pod"},
    					Spec:       v1.PodSpec{},
    					Status: v1.PodStatus{
    						Phase: v1.PodRunning,
    					},
    				},
    				{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 29.8K bytes
    - Viewed (0)
  7. pkg/kubelet/pleg/generic_test.go

    	pleg.Relist()
    	actualEvents := getEventsFromChannel(ch)
    	cases := []struct {
    		pod    *kubecontainer.Pod
    		status *kubecontainer.PodStatus
    		error  error
    	}{
    		{pod: pods[0], status: statuses[0], error: nil},
    		{pod: pods[1], status: &kubecontainer.PodStatus{}, error: statusErr},
    	}
    	for i, c := range cases {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 08:12:16 UTC 2024
    - 24.8K bytes
    - Viewed (0)
  8. pkg/kubelet/container/testing/fake_runtime.go

    	AllPodList        []*FakePod
    	ImageList         []kubecontainer.Image
    	ImageFsStats      []*runtimeapi.FilesystemUsage
    	ContainerFsStats  []*runtimeapi.FilesystemUsage
    	APIPodStatus      v1.PodStatus
    	PodStatus         kubecontainer.PodStatus
    	StartedPods       []string
    	KilledPods        []string
    	StartedContainers []string
    	KilledContainers  []string
    	RuntimeStatus     *kubecontainer.RuntimeStatus
    	VersionInfo       string
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 14 00:23:50 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  9. cni/pkg/util/podutil_test.go

    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "test",
    			Namespace: "test",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: "derp",
    		},
    		Status: corev1.PodStatus{
    			PodIP: "11.1.1.12",
    		},
    	}
    
    	podIPs := GetPodIPsIfPresent(pod)
    	assert.Equal(t, len(podIPs), 1)
    }
    
    func TestGetPodIPsIfPodIPPresent(t *testing.T) {
    	pod := &corev1.Pod{
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri May 03 19:29:42 UTC 2024
    - 4.9K bytes
    - Viewed (0)
  10. pilot/pkg/serviceregistry/kube/controller/ambient/workloads_test.go

    				Spec: v1.PodSpec{},
    				Status: v1.PodStatus{
    					Phase: v1.PodPending,
    				},
    			},
    			result: nil,
    		},
    		{
    			name:   "simple pod not running but have podIP",
    			inputs: []any{},
    			pod: &v1.Pod{
    				TypeMeta: metav1.TypeMeta{},
    				ObjectMeta: metav1.ObjectMeta{
    					Name:      "name",
    					Namespace: "ns",
    				},
    				Spec: v1.PodSpec{},
    				Status: v1.PodStatus{
    					Phase: v1.PodPending,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 13 16:51:29 UTC 2024
    - 20.3K bytes
    - Viewed (0)
Back to top