Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for matchNodeInclusionPolicies (0.31 sec)

  1. pkg/scheduler/framework/plugins/podtopologyspread/common.go

    	Selector           labels.Selector
    	MinDomains         int32
    	NodeAffinityPolicy v1.NodeInclusionPolicy
    	NodeTaintsPolicy   v1.NodeInclusionPolicy
    }
    
    func (tsc *topologySpreadConstraint) matchNodeInclusionPolicies(pod *v1.Pod, node *v1.Node, require nodeaffinity.RequiredNodeAffinity) bool {
    	if tsc.NodeAffinityPolicy == v1.NodeInclusionPolicyHonor {
    		// We ignore parsing errors here for backwards compatibility.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 10:42:29 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/podtopologyspread/filtering.go

    	for _, constraint := range s.Constraints {
    		if !constraint.Selector.Matches(podLabelSet) {
    			continue
    		}
    
    		if pl.enableNodeInclusionPolicyInPodTopologySpread &&
    			!constraint.matchNodeInclusionPolicies(preemptorPod, node, requiredSchedulingTerm) {
    			continue
    		}
    
    		k, v := constraint.TopologyKey, node.Labels[constraint.TopologyKey]
    		pair := topologyPair{key: k, value: v}
    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

    			return
    		}
    
    		for _, c := range state.Constraints {
    			if pl.enableNodeInclusionPolicyInPodTopologySpread &&
    				!c.matchNodeInclusionPolicies(pod, node, requiredNodeAffinity) {
    				continue
    			}
    
    			pair := topologyPair{key: c.TopologyKey, value: node.Labels[c.TopologyKey]}
    			// If current topology pair is not associated with any candidate node,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 10.1K bytes
    - Viewed (0)
Back to top