- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for GetRequiredNodeAffinity (0.32 sec)
-
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) -
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) -
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) -
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)