- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 191 for poda (0.05 sec)
-
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/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/kubelet/util/manager/cache_based_manager_test.go
store.AddReference("ns1", "name1", "pod1") store.AddReference("ns2", "name2", "pod2") store.AddReference("ns1", "name1", "pod3") store.AddReference("ns1", "name1", "pod4") store.DeleteReference("ns1", "name1", "pod1") store.DeleteReference("ns2", "name2", "pod2") store.AddReference("ns3", "name3", "pod5") // Adds don't issue Get requests. actions := fakeClient.Actions()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.6K bytes - Viewed (0) -
pkg/quota/v1/evaluator/core/pods.go
} func toExternalPodOrError(obj runtime.Object) (*corev1.Pod, error) { pod := &corev1.Pod{} switch t := obj.(type) { case *corev1.Pod: pod = t case *api.Pod: if err := k8s_api_v1.Convert_core_Pod_To_v1_Pod(t, pod, nil); err != nil { return nil, err } default: return nil, fmt.Errorf("expect *api.Pod or *v1.Pod, got %v", t) } return pod, nil }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 05 00:02:47 UTC 2023 - 17.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)