Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for pidStatus (0.14 sec)

  1. pkg/kubelet/status/status_manager_test.go

    		oldPodStatus                  func(input v1.PodStatus) v1.PodStatus
    		newPodStatus                  func(input v1.PodStatus) v1.PodStatus
    		expectPodStatus               v1.PodStatus
    	}{
    		{
    			"no change",
    			false,
    			false,
    			func(input v1.PodStatus) v1.PodStatus { return input },
    			func(input v1.PodStatus) v1.PodStatus { return input },
    			getPodStatus(),
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 02 16:27:19 UTC 2024
    - 68.1K bytes
    - Viewed (0)
  2. pkg/kubelet/kuberuntime/kuberuntime_manager_test.go

    	makeAndSetFakePod(t, m, fakeRuntime, pod)
    
    	podStatus, err := m.GetPodStatus(ctx, pod.UID, pod.Name, pod.Namespace)
    	assert.NoError(t, err)
    	assert.Equal(t, pod.UID, podStatus.ID)
    	assert.Equal(t, pod.Name, podStatus.Name)
    	assert.Equal(t, pod.Namespace, podStatus.Namespace)
    	assert.Equal(t, apitest.FakePodSandboxIPs, podStatus.IPs)
    }
    
    func TestStopContainerWithNotFoundError(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 96K bytes
    - Viewed (0)
  3. pkg/kubelet/kuberuntime/kuberuntime_manager.go

    }
    
    func shouldRestartOnFailure(pod *v1.Pod) bool {
    	return pod.Spec.RestartPolicy != v1.RestartPolicyNever
    }
    
    func containerSucceeded(c *v1.Container, podStatus *kubecontainer.PodStatus) bool {
    	cStatus := podStatus.FindContainerStatusByName(c.Name)
    	if cStatus == nil || cStatus.State == kubecontainer.ContainerStateRunning {
    		return false
    	}
    	return cStatus.ExitCode == 0
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 22 02:01:31 UTC 2024
    - 64.7K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  7. pkg/controller/endpointslice/endpointslice_controller_test.go

    			ResourceVersion:   fmt.Sprint(n),
    		},
    		Spec: v1.PodSpec{
    			Containers: []v1.Container{{
    				Name: "container-1",
    			}},
    			NodeName: "node-1",
    		},
    		Status: v1.PodStatus{
    			PodIP: fmt.Sprintf("1.2.3.%d", 4+n),
    			PodIPs: []v1.PodIP{{
    				IP: fmt.Sprintf("1.2.3.%d", 4+n),
    			}},
    			Conditions: []v1.PodCondition{
    				{
    					Type:   v1.PodReady,
    					Status: status,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 08:33:32 UTC 2024
    - 65.5K bytes
    - Viewed (0)
  8. pkg/controller/disruption/disruption_test.go

    			Name:            name,
    			Namespace:       metav1.NamespaceDefault,
    			ResourceVersion: "18",
    			Labels:          fooBar(),
    		},
    		Spec: v1.PodSpec{},
    		Status: v1.PodStatus{
    			Conditions: []v1.PodCondition{
    				{Type: v1.PodReady, Status: v1.ConditionTrue},
    			},
    		},
    	}
    
    	podName, err := controller.KeyFunc(pod)
    	if err != nil {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 50K bytes
    - Viewed (0)
  9. pkg/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go

    						},
    						PersistentVolumeClaim: &v1.PersistentVolumeClaimVolumeSource{
    							ClaimName: pvc,
    						},
    					},
    				},
    			},
    			Containers: containers,
    		},
    		Status: v1.PodStatus{
    			Phase: v1.PodPhase("Running"),
    		},
    	}
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 51.4K bytes
    - Viewed (0)
  10. pilot/pkg/serviceregistry/serviceregistry_test.go

    		},
    	}
    	pod := &v1.Pod{
    		ObjectMeta: metav1.ObjectMeta{
    			Name:        "pod",
    			Namespace:   namespace,
    			Labels:      labels,
    			Annotations: map[string]string{},
    		},
    		Status: v1.PodStatus{
    			PodIP: "1.2.3.4",
    			Phase: v1.PodPending,
    		},
    	}
    	workloadEntry := config.Config{
    		Meta: config.Meta{
    			Name:             "workload",
    			Namespace:        namespace,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Thu May 23 21:07:03 UTC 2024
    - 51.2K bytes
    - Viewed (0)
Back to top