- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 615 for pod9 (5.82 sec)
-
pkg/controller/disruption/disruption_test.go
// This verifies that when a PDB has 0 pods, disruptions are not allowed. ps.VerifyDisruptionAllowed(t, pdbName, 0) pod, _ := newPod(t, "unmanaged") add(t, dc.podStore, pod) dc.sync(ctx, pdbName) var pods []*v1.Pod pods = append(pods, pod) _, unmanagedPods, _ := dc.getExpectedScale(ctx, pdb, pods) if len(unmanagedPods) != 1 { t.Fatalf("expected one pod to be unmanaged pod but found %d", len(unmanagedPods)) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 50K 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) -
plugin/pkg/admission/serviceaccount/admission_test.go
// clear generated volume names for i := range pod.Spec.Volumes { if len(pod.Spec.Volumes[i].Name) > 0 { pod.Spec.Volumes[i].Name = "cleared" } } for i := range pod.Spec.Containers[0].VolumeMounts { if len(pod.Spec.Containers[0].VolumeMounts[i].Name) > 0 { pod.Spec.Containers[0].VolumeMounts[i].Name = "cleared" } } if !reflect.DeepEqual(expectedVolumes, pod.Spec.Volumes) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 12 17:49:30 UTC 2024 - 36.9K bytes - Viewed (0) -
pkg/controller/volume/attachdetach/cache/desired_state_of_world_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Mar 01 10:42:15 UTC 2024 - 35.9K bytes - Viewed (0) -
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) -
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) -
pkg/scheduler/framework/plugins/noderesources/fit_test.go
}) } return &v1.Pod{ Spec: v1.PodSpec{ Containers: containers, }, } } func newResourceInitPod(pod *v1.Pod, usage ...framework.Resource) *v1.Pod { pod.Spec.InitContainers = newResourcePod(usage...).Spec.Containers return pod } func newResourceOverheadPod(pod *v1.Pod, overhead v1.ResourceList) *v1.Pod { pod.Spec.Overhead = overhead return pod }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 57.4K bytes - Viewed (0) -
pkg/controller/daemon/util/daemonset_util_test.go
tests := []struct { pod *v1.Pod nodeName string expectedErr bool }{ { pod: &v1.Pod{ ObjectMeta: metav1.ObjectMeta{ Name: "pod1", Namespace: "default", }, Spec: v1.PodSpec{ NodeName: "node-1", }, }, nodeName: "node-1", }, { pod: &v1.Pod{ ObjectMeta: metav1.ObjectMeta{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 14.5K bytes - Viewed (0) -
pkg/kubelet/volumemanager/reconciler/reconstruct_test.go
for _, tpodInfo := range tc.podInfos { pod := getInlineFakePod(tpodInfo.podName, tpodInfo.podUID, tpodInfo.outerVolumeName, tpodInfo.innerVolumeName) volumeSpec := &volume.Spec{Volume: &pod.Spec.Volumes[0]} podName := util.GetUniquePodName(pod) volumeName, err := rcInstance.desiredStateOfWorld.AddPodToVolume( podName, pod, volumeSpec, volumeSpec.Name(), "" /* volumeGidValue */, nil /* SELinuxContext */)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 14.8K bytes - Viewed (0) -
pkg/controller/statefulset/stateful_pod_control_test.go
pvcs := getPersistentVolumeClaims(set, pod) volumes := make([]v1.Volume, 0, len(pod.Spec.Volumes)) for i := range pod.Spec.Volumes { if _, contains := pvcs[pod.Spec.Volumes[i].Name]; !contains { volumes = append(volumes, pod.Spec.Volumes[i]) } } pod.Spec.Volumes = volumes fakeClient.AddReactor("update", "pods", func(action core.Action) (bool, runtime.Object, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 05 19:06:41 UTC 2024 - 35.5K bytes - Viewed (0)