- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for PodPriority (0.25 sec)
-
pkg/kubeapiserver/options/plugins.go
"k8s.io/kubernetes/plugin/pkg/admission/nodetaint" "k8s.io/kubernetes/plugin/pkg/admission/podnodeselector" "k8s.io/kubernetes/plugin/pkg/admission/podtolerationrestriction" podpriority "k8s.io/kubernetes/plugin/pkg/admission/priority" "k8s.io/kubernetes/plugin/pkg/admission/runtimeclass" "k8s.io/kubernetes/plugin/pkg/admission/security/podsecurity" "k8s.io/kubernetes/plugin/pkg/admission/serviceaccount"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 20 17:20:46 UTC 2024 - 8.2K bytes - Viewed (0) -
pkg/scheduler/testing/framework/fake_extender.go
nodeInfoCopy.AddPod(ap) } // As the first step, remove all the lower priority pods from the node and // check if the given pod can be scheduled. podPriority := corev1helpers.PodPriority(pod) for _, p := range nodeInfoCopy.Pods { if corev1helpers.PodPriority(p.Pod) < podPriority { potentialVictims = append(potentialVictims, p.Pod) if err := removePod(p.Pod); err != nil { return nil, 0, false, err } } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 13.9K bytes - Viewed (0) -
pkg/scheduler/framework/preemption/preemption.go
podInfos := pn.NominatedPodsForNode(nodeName) if len(podInfos) == 0 { return nil } var lowerPriorityPods []*v1.Pod podPriority := corev1helpers.PodPriority(pod) for _, pi := range podInfos { if corev1helpers.PodPriority(pi.Pod) < podPriority { lowerPriorityPods = append(lowerPriorityPods, pi.Pod) } } return lowerPriorityPods }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 25.1K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
return false, state, nodeInfo, nil } nodeInfoOut := nodeInfo.Snapshot() stateOut := state.Clone() podsAdded := false for _, pi := range nominatedPodInfos { if corev1.PodPriority(pi.Pod) >= corev1.PodPriority(pod) && pi.Pod.UID != pod.UID { nodeInfoOut.AddPodInfo(pi) status := fh.RunPreFilterExtensionAddPod(ctx, stateOut, pod, pi, nodeInfoOut) if !status.IsSuccess() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
pkg/kubelet/eviction/eviction_manager_test.go
} pods[0].Annotations = map[string]string{ kubelettypes.ConfigSourceAnnotationKey: kubelettypes.FileSource, } // Mark the pod as critical podPriority := scheduling.SystemCriticalPriority pods[0].Spec.Priority = &podPriority pods[0].Namespace = kubeapi.NamespaceSystem podToEvict := pods[0] 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/controller/daemon/daemon_controller_test.go
ds.Namespace = api.NamespaceSystem if ds.Spec.Template.ObjectMeta.Annotations == nil { ds.Spec.Template.ObjectMeta.Annotations = make(map[string]string) } podPriority := scheduling.SystemCriticalPriority ds.Spec.Template.Spec.Priority = &podPriority } func TestNodeShouldRunDaemonPod(t *testing.T) { shouldRun := true shouldContinueRunning := true cases := []struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 111.4K bytes - Viewed (0)