- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for enableNodeInclusionPolicyInPodTopologySpread (0.54 sec)
-
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. if match, _ := requiredSchedulingTerm.Match(node); !match { return } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 10:42:29 UTC 2024 - 12.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/plugin.go
} pl := &PodTopologySpread{ parallelizer: h.Parallelizer(), sharedLister: h.SnapshotSharedLister(), defaultConstraints: args.DefaultConstraints, enableNodeInclusionPolicyInPodTopologySpread: fts.EnableNodeInclusionPolicyInPodTopologySpread, enableMatchLabelKeysInPodTopologySpread: fts.EnableMatchLabelKeysInPodTopologySpread, } if args.DefaultingType == config.SystemDefaulting {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:13:06 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/scoring.go
requiredNodeAffinity := nodeaffinity.GetRequiredNodeAffinity(pod) processAllNode := func(i int) { nodeInfo := allNodes[i] node := nodeInfo.Node() if !pl.enableNodeInclusionPolicyInPodTopologySpread { // `node` should satisfy incoming pod's NodeSelector/NodeAffinity if match, _ := requiredNodeAffinity.Match(node); !match { return } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 10.1K bytes - Viewed (0)