Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for pod3 (0.04 sec)

  1. pkg/kubelet/kubelet_test.go

    	// resources)
    	pods[7].Status.Phase = v1.PodFailed
    	kubelet.podWorkers.(*fakePodWorkers).terminationRequested = map[types.UID]bool{
    		pods[7].UID: true,
    	}
    
    	expected := []*v1.Pod{pods[2], pods[3], pods[4], pods[7]}
    	kubelet.podManager.SetPods(pods)
    	actual := kubelet.filterOutInactivePods(pods)
    	assert.Equal(t, expected, actual)
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 14 16:09:17 UTC 2024
    - 106.9K bytes
    - Viewed (0)
  2. pkg/scheduler/internal/queue/scheduling_queue_test.go

    				// This Pod won't be requeued again.
    				{podPopped: pod3},
    				{eventHappens: &AssignedPodAdd},
    				{podEnqueued: newQueuedPodInfoForLookup(pod2)},
    			},
    			wantBackoffQPodNames: []string{"targetpod2"},
    			wantInFlightPods:     []*v1.Pod{pod, pod3},
    			wantInFlightEvents:   []interface{}{pod, PvAdd, NodeAdd, pod3, AssignedPodAdd},
    			queueingHintMap: QueueingHintMapPerProfile{
    				"": {
    					PvAdd: {
    						{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
  3. pkg/controller/job/job_controller_test.go

    						Failed: []types.UID{"a", "b"},
    					},
    				},
    			},
    			pods: func() []*v1.Pod {
    				pods := make([]*v1.Pod, 500)
    				for i := range pods {
    					pods[i] = buildPod().uid(strconv.Itoa(i)).phase(v1.PodSucceeded).trackingFinalizer().Pod
    				}
    				pods = append(pods, buildPod().uid("b").phase(v1.PodFailed).trackingFinalizer().Pod)
    				return pods
    			}(),
    			wantRmFinalizers: 499,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 15:36:36 UTC 2024
    - 229.2K bytes
    - Viewed (0)
  4. staging/src/k8s.io/apiserver/pkg/registry/generic/registry/store_test.go

    			out: &example.PodList{Items: []example.Pod{}},
    		},
    		"normal": {
    			in:  &example.PodList{Items: []example.Pod{*podA, *podB}},
    			m:   matchEverything(),
    			out: &example.PodList{Items: []example.Pod{*podA, *podB}},
    		},
    		"normalFiltered": {
    			in:  &example.PodList{Items: []example.Pod{*podA, *podB}},
    			m:   matchPodName("foo"),
    			out: &example.PodList{Items: []example.Pod{*podB}},
    		},
    		"normalFilteredNoNamespace": {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 10:12:02 UTC 2024
    - 101.8K bytes
    - Viewed (0)
  5. pkg/kubelet/kubelet_pods_test.go

    		message string
    	}
    	simplePod := func() *v1.Pod {
    		return &v1.Pod{
    			ObjectMeta: metav1.ObjectMeta{Name: "pod1", Namespace: "ns1", UID: types.UID("1")},
    			Spec: v1.PodSpec{
    				Containers: []v1.Container{
    					{Name: "container-1"},
    				},
    			},
    		}
    	}
    	withPhase := func(pod *v1.Pod, phase v1.PodPhase) *v1.Pod {
    		pod.Status.Phase = phase
    		return pod
    	}
    	staticPod := func() *v1.Pod {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jun 07 00:05:23 UTC 2024
    - 198.8K bytes
    - Viewed (0)
  6. pkg/kubelet/kubelet_pods.go

    // or are known to be fully terminated. This method should only be used
    // when the set of pods being filtered is upstream of the pod worker, i.e.
    // the pods the pod manager is aware of.
    func (kl *Kubelet) filterOutInactivePods(pods []*v1.Pod) []*v1.Pod {
    	filteredPods := make([]*v1.Pod, 0, len(pods))
    	for _, p := range pods {
    		// if a pod is fully terminated by UID, it should be excluded from the
    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/printers/internalversion/printers.go

    	case api.PodSucceeded:
    		row.Conditions = podSuccessConditions
    	case api.PodFailed:
    		row.Conditions = podFailedConditions
    	}
    
    	initContainers := make(map[string]*api.Container)
    	for i := range pod.Spec.InitContainers {
    		initContainers[pod.Spec.InitContainers[i].Name] = &pod.Spec.InitContainers[i]
    		if isRestartableInitContainer(&pod.Spec.InitContainers[i]) {
    			totalContainers++
    		}
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 11 14:04:15 UTC 2024
    - 128.3K bytes
    - Viewed (0)
Back to top