Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for poda (0.05 sec)

  1. 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)
  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/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)
  4. tests/integration/pilot/common/routing.go

    				//	host: fmt.Sprintf("%s-v1-0.%s", StatefulSetSvc, apps.StatefulSet[0].Config().ClusterLocalFQDN()),
    				//},
    			)
    		}
    		for _, podA := range t.Apps.A {
    			testCases = append(testCases, vmCase{
    				name: "k8s to vm",
    				from: podA,
    				to:   vms,
    			})
    		}
    		for _, c := range testCases {
    			c := c
    			checker := check.OK()
    			if !match.Headless.Any(c.to) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed May 08 21:52:51 UTC 2024
    - 135.9K bytes
    - Viewed (0)
  5. pkg/scheduler/schedule_one_test.go

    				ForgetFunc: func(pod *v1.Pod) {
    					gotForgetPod = pod
    				},
    				AssumeFunc: func(pod *v1.Pod) {
    					gotAssumedPod = pod
    				},
    				IsAssumedPodFunc: func(pod *v1.Pod) bool {
    					if pod == nil || gotAssumedPod == nil {
    						return false
    					}
    					return pod.UID == gotAssumedPod.UID
    				},
    			}
    			client := clientsetfake.NewSimpleClientset(item.sendPod)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 128.1K bytes
    - Viewed (0)
  6. pkg/kubelet/cm/memorymanager/policy_static_test.go

    			}
    
    			for i := range testCase.pod.Spec.InitContainers {
    				err = p.Allocate(s, testCase.pod, &testCase.pod.Spec.InitContainers[i])
    				if !reflect.DeepEqual(err, testCase.expectedError) {
    					t.Fatalf("The actual error %v is different from the expected one %v", err, testCase.expectedError)
    				}
    			}
    
    			for i := range testCase.pod.Spec.Containers {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sun Sep 17 05:49:15 UTC 2023
    - 100.4K bytes
    - Viewed (0)
  7. 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)
  8. pkg/scheduler/internal/queue/scheduling_queue_test.go

    		t.Errorf("Unexpected diff after adding pods (-want, +got):\n%s", diff)
    	}
    	if p, err := q.Pop(logger); err != nil || p.Pod != highPriorityPodInfo.Pod {
    		t.Errorf("Expected: %v after Pop, but got: %v", highPriorityPodInfo.Pod.Name, p.Pod.Name)
    	}
    	if p, err := q.Pop(logger); err != nil || p.Pod != medPriorityPodInfo.Pod {
    		t.Errorf("Expected: %v after Pop, but got: %v", medPriorityPodInfo.Pod.Name, p.Pod.Name)
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
  9. 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)
  10. 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)
Back to top