- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for pod3 (0.04 sec)
-
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/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/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/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)