- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 453 for pod4 (0.14 sec)
-
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/kubelet/preemption/preemption.go
// subtract the pod from requirements, and transfer the pod from input-pods to pods-to-evicted requirements = requirements.subtract(pods[bestPodIndex]) podsToEvict = append(podsToEvict, pods[bestPodIndex]) pods[bestPodIndex] = pods[len(pods)-1] pods = pods[:len(pods)-1] } return podsToEvict, nil } type admissionRequirement struct { resourceName v1.ResourceName quantity int64 }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 02 16:53:19 UTC 2023 - 11.5K 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/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) -
cmd/kubeadm/app/util/staticpod/utils.go
} pod2, ok := obj.(*v1.Pod) if !ok { return pod, errors.Wrap(err, "patched manifest is not a valid Pod object") } return pod2, nil } // WriteStaticPodToDisk writes a static pod file to disk func WriteStaticPodToDisk(componentName, manifestDir string, pod v1.Pod) error { // creates target folder if not already exists if err := os.MkdirAll(manifestDir, 0700); err != nil {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sun Jan 14 13:07:56 UTC 2024 - 14.1K bytes - Viewed (0) -
pkg/kubelet/util/manager/watch_based_manager_test.go
steps: []step{ {"add", "ns1", "secret1", "pod1"}, {"add", "ns1", "secret1", "pod1"}, {"delete", "ns1", "secret1", "pod1"}, {"delete", "ns1", "secret1", "pod1"}, }, expects: []expect{ {"ns1", "secret1", "pod1", 1}, {"ns1", "secret1", "pod1", 2}, {"ns1", "secret1", "pod1", 1}, {"ns1", "secret1", "pod1", 0}, }, }, {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 09 10:05:43 UTC 2023 - 17.2K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/cacher/watch_cache_interval_test.go
} } func TestCacheIntervalNextFromStore(t *testing.T) { getAttrsFunc := func(obj runtime.Object) (labels.Set, fields.Set, error) { pod, ok := obj.(*v1.Pod) if !ok { return nil, nil, fmt.Errorf("not a pod") } return labels.Set(pod.Labels), fields.Set{"spec.nodeName": pod.Spec.NodeName}, nil } const numEvents = 50 store := cache.NewIndexer(storeElementKey, storeElementIndexers(nil))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 09:20:10 UTC 2024 - 11.6K bytes - Viewed (0) -
pkg/volume/fc/fc_test.go
} fm := mount.NewFakeMounter( []mount.MountPoint{ {Device: "/dev/sdb", Path: "/var/lib/kubelet/pods/some-pod/volumes/kubernetes.io~fc/fc-in-pod1"}, {Device: "/dev/sdb", Path: "/var/lib/kubelet/plugins/kubernetes.io/fc/50060e801049cfd1-lun-0"}, {Device: "/dev/sdc", Path: "/var/lib/kubelet/pods/some-pod/volumes/kubernetes.io~fc/fc-in-pod2"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Aug 01 15:56:32 UTC 2022 - 14.1K bytes - Viewed (0) -
cni/pkg/nodeagent/net_test.go
err := netServer.syncHostIPSets([]*corev1.Pod{pod}) assert.NoError(t, err) fakeIPSetDeps.AssertExpectations(t) } func TestSyncHostIPSetsIgnoresPodIPAddErrorAndContinues(t *testing.T) { pod1 := buildConvincingPod(false) pod2 := buildConvincingPod(false) pod2.ObjectMeta.SetUID("4455") fakeIPSetDeps := ipset.FakeNLDeps() var pod1UID string = string(pod1.ObjectMeta.UID)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 05:10:23 UTC 2024 - 17.8K 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)