Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 21 for pod3 (0.08 sec)

  1. pkg/kubelet/eviction/helpers_test.go

    		pod8: newPodMemoryStats(pod8, resource.MustParse("200Mi")), // -800 relative to request
    	}
    	statsFn := func(pod *v1.Pod) (statsapi.PodStats, bool) {
    		result, found := stats[pod]
    		return result, found
    	}
    	pods := []*v1.Pod{pod8, pod7, pod6, pod5, pod4, pod3, pod2, pod1}
    	expected := []*v1.Pod{pod1, pod2, pod3, pod4, pod5, pod6, pod7, pod8}
    	orderedBy(exceedMemoryRequests(statsFn), priority, memory(statsFn)).Sort(pods)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 15 23:14:12 UTC 2024
    - 106.7K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. pkg/scheduler/schedule_one_test.go

    		st.MakeNode().Name("node3").UID("node3").Obj(),
    	}
    	pods := []*v1.Pod{
    		st.MakePod().Name("pod1").UID("pod1").SchedulerName("match-node3").Obj(),
    		st.MakePod().Name("pod2").UID("pod2").SchedulerName("match-node2").Obj(),
    		st.MakePod().Name("pod3").UID("pod3").SchedulerName("match-node2").Obj(),
    		st.MakePod().Name("pod4").UID("pod4").SchedulerName("match-node3").Obj(),
    	}
    	wantBindings := map[string]string{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. pkg/controller/daemon/daemon_controller_test.go

    			gotPods := map[string]bool{}
    			for node, pods := range nodesToDaemonPods {
    				for _, pod := range pods {
    					if pod.Spec.NodeName != node {
    						t.Errorf("pod %v grouped into %v but belongs in %v", pod.Name, node, pod.Spec.NodeName)
    					}
    					gotPods[pod.Name] = true
    				}
    			}
    			for _, pod := range tc.wantedPods {
    				if !gotPods[pod.Name] {
    					t.Errorf("expected pod %v but didn't get it", pod.Name)
    				}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.4K bytes
    - Viewed (0)
  8. 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)
  9. pkg/controller/garbagecollector/garbagecollector_test.go

    		}
    	}()
    	wg.Wait()
    }
    
    func podToGCNode(pod *v1.Pod) *node {
    	return &node{
    		identity: objectReference{
    			OwnerReference: metav1.OwnerReference{
    				Kind:       pod.Kind,
    				APIVersion: pod.APIVersion,
    				Name:       pod.Name,
    				UID:        pod.UID,
    			},
    			Namespace: pod.Namespace,
    		},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 111.6K bytes
    - Viewed (0)
  10. pkg/controller/nodelifecycle/node_lifecycle_controller_test.go

    					},
    				},
    			}
    		}
    		return nodes
    	}
    	makePods := func() []v1.Pod {
    		pods := make([]v1.Pod, numNodes*podsPerNode)
    		for i := 0; i < numNodes*podsPerNode; i++ {
    			pods[i] = *testutil.NewPod(fmt.Sprintf("pod%d", i), fmt.Sprintf("node%d", i%numNodes))
    		}
    		return pods
    	}
    
    	table := []struct {
    		workers int
    	}{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Feb 26 03:26:45 UTC 2024
    - 119K bytes
    - Viewed (0)
Back to top