Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for PodPriority (0.25 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
Back to top