Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 83 for pidStatus (0.15 sec)

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

    // targeting. The target is stored as EphemeralContainer.TargetContainerName, which must be
    // resolved to a ContainerID using podStatus. The target container must already exist, which
    // usually isn't a problem since ephemeral containers aren't allowed at pod creation time.
    func (s *startSpec) getTargetID(podStatus *kubecontainer.PodStatus) (*kubecontainer.ContainerID, error) {
    	if s.ephemeralContainer == nil || s.ephemeralContainer.TargetContainerName == "" {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 54.7K bytes
    - Viewed (0)
  5. pkg/registry/core/pod/strategy_test.go

    			expectMatch:   false,
    		},
    		{
    			in: &api.Pod{
    				Status: api.PodStatus{Phase: api.PodRunning},
    			},
    			fieldSelector: fields.ParseSelectorOrDie("status.phase=Running"),
    			expectMatch:   true,
    		},
    		{
    			in: &api.Pod{
    				Status: api.PodStatus{Phase: api.PodRunning},
    			},
    			fieldSelector: fields.ParseSelectorOrDie("status.phase=Pending"),
    			expectMatch:   false,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 76.2K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_pods.go

    }
    
    // convertStatusToAPIStatus initialize an api PodStatus for the given pod from
    // the given internal pod status and the previous state of the pod from the API.
    // It is purely transformative and does not alter the kubelet state at all.
    func (kl *Kubelet) convertStatusToAPIStatus(pod *v1.Pod, podStatus *kubecontainer.PodStatus, oldPodStatus v1.PodStatus) *v1.PodStatus {
    	var apiPodStatus v1.PodStatus
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 101.2K bytes
    - Viewed (0)
  7. pkg/api/pod/util_test.go

    	podWithHostIPs := func() *api.PodStatus {
    		return &api.PodStatus{
    			HostIPs: makeHostIPs("10.0.0.1", "fd00:10::1"),
    		}
    	}
    
    	podWithoutHostIPs := func() *api.PodStatus {
    		return &api.PodStatus{
    			HostIPs: nil,
    		}
    	}
    
    	tests := []struct {
    		name          string
    		podStatus     *api.PodStatus
    		oldPodStatus  *api.PodStatus
    		wantPodStatus *api.PodStatus
    	}{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 108.8K bytes
    - Viewed (0)
  8. cni/pkg/nodeagent/cni-watcher_test.go

    	defer cancel()
    	pod := &corev1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:      "pod-bingo",
    			Namespace: "funkyns",
    		},
    		Spec: corev1.PodSpec{
    			NodeName: NodeName,
    		},
    		Status: corev1.PodStatus{
    			PodIP: fakePodIP,
    		},
    	}
    	ns := &corev1.Namespace{ObjectMeta: metav1.ObjectMeta{Name: "funkyns"}}
    
    	client := kube.NewFakeClient(ns, pod)
    
    	// We are expecting at most 1 calls to the mock, wait for them
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 21:31:35 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  9. cni/pkg/nodeagent/net_test.go

    		},
    	}
    
    	containers := []corev1.Container{app1}
    
    	var podStatus corev1.PodStatus
    	if v6IP {
    		podStatus = corev1.PodStatus{
    			PodIP:  "e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3164",
    			PodIPs: []corev1.PodIP{{IP: "e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3164"}, {IP: "e9ac:1e77:90ca:399f:4d6d:ece2:2f9b:3165"}},
    		}
    	} else {
    		podStatus = corev1.PodStatus{
    			PodIP:  "2.2.2.2",
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu Jun 06 05:10:23 UTC 2024
    - 17.8K bytes
    - Viewed (0)
  10. pkg/kubelet/kubelet.go

    		podStatus.IPs = append(podStatus.IPs, ipInfo.IP)
    	}
    	if len(podStatus.IPs) == 0 && len(apiPodStatus.PodIP) > 0 {
    		podStatus.IPs = []string{apiPodStatus.PodIP}
    	}
    
    	// If the pod is terminal, we don't need to continue to setup the pod
    	if apiPodStatus.Phase == v1.PodSucceeded || apiPodStatus.Phase == v1.PodFailed {
    		kl.statusManager.SetPodStatus(pod, apiPodStatus)
    		isTerminal = true
    		return isTerminal, nil
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 126.1K bytes
    - Viewed (0)
Back to top