Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for GetRequiredNodeAffinity (0.34 sec)

  1. pkg/scheduler/framework/plugins/nodeaffinity/node_affinity.go

    		return framework.QueueSkip, nil
    	}
    
    	requiredNodeAffinity := nodeaffinity.GetRequiredNodeAffinity(pod)
    	isMatched, err := requiredNodeAffinity.Match(modifiedNode)
    	if err != nil {
    		return framework.Queue, err
    	}
    	if isMatched {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Dec 18 12:00:10 UTC 2023
    - 12.6K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/podtopologyspread/filtering.go

    		return
    	}
    	if !nodeLabelsMatchSpreadConstraints(node.Labels, s.Constraints) {
    		return
    	}
    
    	requiredSchedulingTerm := nodeaffinity.GetRequiredNodeAffinity(preemptorPod)
    	if !pl.enableNodeInclusionPolicyInPodTopologySpread {
    		// spreading is applied to nodes that pass those filters.
    		// Ignore parsing errors for backwards compatibility.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 10:42:29 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/podtopologyspread/scoring.go

    	if len(state.Constraints) == 0 {
    		return framework.NewStatus(framework.Skip)
    	}
    
    	// Ignore parsing errors for backwards compatibility.
    	requiredNodeAffinity := nodeaffinity.GetRequiredNodeAffinity(pod)
    	processAllNode := func(i int) {
    		nodeInfo := allNodes[i]
    		node := nodeInfo.Node()
    
    		if !pl.enableNodeInclusionPolicyInPodTopologySpread {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 10.1K bytes
    - Viewed (0)
  4. pkg/scheduler/eventhandlers.go

    		}
    		if !includeAllFailures {
    			return admissionResults
    		}
    	}
    
    	if matches, _ := corev1nodeaffinity.GetRequiredNodeAffinity(pod).Match(nodeInfo.Node()); !matches {
    		admissionResults = append(admissionResults, AdmissionResult{Name: nodeaffinity.Name, Reason: nodeaffinity.ErrReasonPod})
    		if !includeAllFailures {
    			return admissionResults
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:21:04 UTC 2024
    - 24K bytes
    - Viewed (0)
  5. pkg/controller/daemon/daemon_controller.go

    	fitsNodeName = len(pod.Spec.NodeName) == 0 || pod.Spec.NodeName == node.Name
    	// Ignore parsing errors for backwards compatibility.
    	fitsNodeAffinity, _ = nodeaffinity.GetRequiredNodeAffinity(pod).Match(node)
    	_, hasUntoleratedTaint := v1helper.FindMatchingUntoleratedTaint(taints, pod.Spec.Tolerations, func(t *v1.Taint) bool {
    		return t.Effect == v1.TaintEffectNoExecute || t.Effect == v1.TaintEffectNoSchedule
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat May 04 18:33:12 UTC 2024
    - 51.3K bytes
    - Viewed (0)
Back to top