- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for pod3 (0.15 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
pkg/kubelet/eviction/eviction_manager_test.go
summaryStatsMaker := makePIDStats pods := []*v1.Pod{} podStats := map[*v1.Pod]statsapi.PodStats{} for _, podToMake := range tc.podsToMake { pod, podStat := podMaker(podToMake.name, podToMake.priority, podToMake.pidUsage) pods = append(pods, pod) podStats[pod] = podStat } podToEvict := pods[tc.evictPodIndex] activePodsFunc := func() []*v1.Pod { return pods }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 15 23:14:12 UTC 2024 - 119.9K bytes - Viewed (0) -
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) -
pkg/volume/util/operationexecutor/operation_generator.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 14 06:17:25 UTC 2024 - 101.4K bytes - Viewed (0)