- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 40 for Parallelizer (0.18 sec)
-
pkg/scheduler/framework/parallelize/parallelism.go
limitations under the License. */ package parallelize import ( "context" "math" "k8s.io/client-go/util/workqueue" "k8s.io/kubernetes/pkg/scheduler/metrics" ) // DefaultParallelism is the default parallelism used in scheduler. const DefaultParallelism int = 16 // Parallelizer holds the parallelism for scheduler. type Parallelizer struct { parallelism int }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 09 17:12:30 UTC 2023 - 2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/plugin.go
}, } // PodTopologySpread is a plugin that ensures pod's topologySpreadConstraints is satisfied. type PodTopologySpread struct { systemDefaulted bool parallelizer parallelize.Parallelizer defaultConstraints []v1.TopologySpreadConstraint sharedLister framework.SharedLister
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/interpodaffinity/plugin.go
var _ framework.ScorePlugin = &InterPodAffinity{} var _ framework.EnqueueExtensions = &InterPodAffinity{} // InterPodAffinity is a plugin that checks inter pod affinity type InterPodAffinity struct { parallelizer parallelize.Parallelizer args config.InterPodAffinityArgs sharedLister framework.SharedLister nsLister listersv1.NamespaceLister } // Name returns name of the plugin. It is used in logs, etc.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Apr 12 03:08:44 UTC 2024 - 10.3K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
func (f *frameworkImpl) PercentageOfNodesToScore() *int32 { return f.percentageOfNodesToScore } // Parallelizer returns a parallelizer holding parallelism for scheduler. func (f *frameworkImpl) Parallelizer() parallelize.Parallelizer { return f.parallelizer
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/interpodaffinity/filtering.go
topoMap.updateWithAntiAffinityTerms(existingPod.RequiredAntiAffinityTerms, pod, nsLabels, node, 1) } if len(topoMap) != 0 { topoMaps[atomic.AddInt32(&index, 1)] = topoMap } } pl.parallelizer.Until(ctx, len(nodes), processNode, pl.Name()) result := make(topologyToMatchedTermCount) for i := 0; i <= int(index); i++ { result.append(topoMaps[i]) } return result }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 01 10:24:54 UTC 2023 - 14.6K bytes - Viewed (0) -
pkg/scheduler/framework/interface.go
// Extenders returns registered scheduler extenders. Extenders() []Extender // Parallelizer returns a parallelizer holding parallelism for scheduler. Parallelizer() parallelize.Parallelizer } // PreFilterResult wraps needed info for scheduler framework to act upon PreFilter phase. type PreFilterResult struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0) -
pkg/scheduler/framework/preemption/preemption.go
} fh.EventRecorder().Eventf(victim, pod, v1.EventTypeNormal, "Preempted", "Preempting", "Preempted by pod %v on node %v", pod.UID, c.Name()) } fh.Parallelizer().Until(ctx, len(c.Victims().Pods), preemptPod, ev.PluginName) if err := errCh.ReceiveError(); err != nil { return framework.AsStatus(err) } metrics.PreemptionVictims.Observe(float64(len(c.Victims().Pods)))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 25.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/interpodaffinity/scoring.go
pl.processExistingPod(state, existingPod, nodeInfo, pod, topoScore) } if len(topoScore) > 0 { topoScores[atomic.AddInt32(&index, 1)] = topoScore } } pl.parallelizer.Until(pCtx, len(allNodes), processNode, pl.Name()) if index == -1 { return framework.NewStatus(framework.Skip) } for i := 0; i <= int(index); i++ { state.topologyScore.append(topoScores[i]) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 10.5K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/scoring.go
if tpCount == nil { continue } count := countPodsMatchSelector(nodeInfo.Pods, c.Selector, pod.Namespace) atomic.AddInt64(tpCount, int64(count)) } } pl.parallelizer.Until(ctx, len(allNodes), processAllNode, pl.Name()) cycleState.Write(preScoreStateKey, state) return nil } // Score invoked at the Score extension point.
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/framework/plugins/podtopologyspread/filtering.go
count := countPodsMatchSelector(nodeInfo.Pods, c.Selector, pod.Namespace) tpCounts[pair] = count } tpCountsByNode[i] = tpCounts } pl.parallelizer.Until(ctx, len(allNodes), processNode, pl.Name()) for _, tpCounts := range tpCountsByNode { for tp, count := range tpCounts { s.TpPairToMatchNum[tp] += count } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 10:42:29 UTC 2024 - 12.4K bytes - Viewed (0)