- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 24 for Parallelizer (0.23 sec)
-
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/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/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) -
pkg/scheduler/schedule_one.go
}() // Stops searching for more nodes once the configured number of feasible nodes // are found. fwk.Parallelizer().Until(ctx, numAllNodes, checkNode, metrics.Filter) feasibleNodes = feasibleNodes[:feasibleNodesLen] for _, item := range result { if item == nil { continue }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Jun 06 13:28:08 UTC 2024 - 43.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/podtopologyspread/filtering_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Feb 28 10:42:29 UTC 2024 - 143.1K bytes - Viewed (0) -
src/syscall/rlimit.go
// (limited by the size of fd_set). // // Go does not use select, so it should not be subject to these limits. // On some systems the limit is 256, which is very easy to run into, // even in simple programs like gofmt when they parallelize walking // a file tree. // // After a long discussion on go.dev/issue/46279, we decided the // best approach was for Go to raise the limit unconditionally for itself,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Jun 07 20:13:57 UTC 2024 - 1.6K bytes - Viewed (0) -
.teamcity/src/main/kotlin/model/FunctionalTestBucketGenerator.kt
return parallelize(subProjectTestClassTimes, testCoverage) { numberOfBatches -> if (testCoverage.os == Os.LINUX) ParallelizationMethod.TestDistribution else ParallelizationMethod.TeamCityParallelTests(numberOfBatches) } } private fun parallelize( subProjectTestClassTimes: List<SubprojectTestClassTime>,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Feb 15 17:04:41 UTC 2024 - 8.5K bytes - Viewed (0)