Search Options

Results per page
Sort
Preferred Languages
Advance

Results 71 - 80 of 208 for podStates (0.18 sec)

  1. pkg/kubelet/stats/cri_stats_provider.go

    	// sandboxIDToPodStats is a temporary map from sandbox ID to its pod stats.
    	sandboxIDToPodStats := make(map[string]*statsapi.PodStats)
    	containerMap, podSandboxMap, err := p.getPodAndContainerMaps(ctx)
    	if err != nil {
    		return nil, fmt.Errorf("failed to get pod or container map: %v", err)
    	}
    
    	result := make([]statsapi.PodStats, 0, len(podSandboxMap))
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Nov 01 18:46:33 UTC 2023
    - 35.1K bytes
    - Viewed (0)
  2. 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)
  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. 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)
  6. pkg/kubelet/volumemanager/populator/desired_state_of_world_populator_test.go

    	tests := []struct {
    		desc          string
    		hasAddedPods  bool
    		podState      string
    		expectedFound bool // Found pod is added to DSW
    	}{
    		{
    			desc:          "HasAddedPods is false, ShouldPodRuntimeBeRemoved and ShouldPodContainerBeTerminating are both true",
    			hasAddedPods:  false,
    			podState:      Removed,
    			expectedFound: false, // Pod should not be added to DSW
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 51.4K bytes
    - Viewed (0)
  7. pkg/kubelet/stats/cri_stats_provider_windows.go

    	}
    }
    
    func addCRIPodProcessStats(ps *statsapi.PodStats, criPodStat *runtimeapi.PodSandboxStats) {
    	if criPodStat == nil || criPodStat.Windows == nil || criPodStat.Windows.Process == nil {
    		return
    	}
    	ps.ProcessStats = &statsapi.ProcessStats{
    		ProcessCount: valueOfUInt64Value(criPodStat.Windows.Process.ProcessCount),
    	}
    }
    
    func addCRIPodNetworkStats(ps *statsapi.PodStats, criPodStat *runtimeapi.PodSandboxStats) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Feb 18 07:03:11 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  8. pkg/api/v1/pod/util.go

    func IsPodReadyConditionTrue(status v1.PodStatus) bool {
    	condition := GetPodReadyCondition(status)
    	return condition != nil && condition.Status == v1.ConditionTrue
    }
    
    // IsContainersReadyConditionTrue returns true if a pod is ready; false otherwise.
    func IsContainersReadyConditionTrue(status v1.PodStatus) bool {
    	condition := GetContainersReadyCondition(status)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 24 17:18:04 UTC 2023
    - 13.2K bytes
    - Viewed (0)
  9. 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)
  10. pkg/registry/core/pod/storage/storage_test.go

    	}{
    		{
    			pod: api.Pod{
    				ObjectMeta: metav1.ObjectMeta{Name: "foo"},
    				Status:     api.PodStatus{PodIPs: []api.PodIP{{IP: expectedIP}}},
    			},
    			query:    "foo",
    			location: expectedIP,
    		},
    		{
    			pod: api.Pod{
    				ObjectMeta: metav1.ObjectMeta{Name: "foo"},
    				Status:     api.PodStatus{PodIPs: []api.PodIP{{IP: expectedIP}}},
    			},
    			query:    "foo:12345",
    			location: expectedIP + ":12345",
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Feb 29 07:18:44 UTC 2024
    - 38.8K bytes
    - Viewed (0)
Back to top