- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 18 for QueueSort (0.18 sec)
-
pkg/scheduler/apis/config/validation/validation.go
if profiles[0].Plugins != nil { canon = profiles[0].Plugins.QueueSort if len(profiles[0].Plugins.QueueSort.Enabled) != 0 { queueSortName = profiles[0].Plugins.QueueSort.Enabled[0].Name } length := len(profiles[0].Plugins.QueueSort.Enabled) if length > 1 { errs = append(errs, field.Invalid(path.Index(0).Child("plugins", "queueSort", "Enabled"), length, "only one queue sort plugin can be enabled")) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 06:27:01 UTC 2024 - 11.5K bytes - Viewed (0) -
pkg/scheduler/scheduler_test.go
Plugins: &schedulerapi.Plugins{ QueueSort: schedulerapi.PluginSet{Enabled: []schedulerapi.Plugin{{Name: "PrioritySort"}}}, Bind: schedulerapi.PluginSet{Enabled: []schedulerapi.Plugin{{Name: "DefaultBinder"}}}, }, }, schedulerapi.KubeSchedulerProfile{ SchedulerName: "bar", Plugins: &schedulerapi.Plugins{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 42K bytes - Viewed (0) -
pkg/scheduler/profile/profile.go
} queueSort := f.ListPlugins().QueueSort.Enabled[0].Name var queueSortArgs runtime.Object for _, plCfg := range cfg.PluginConfig { if plCfg.Name == queueSort { queueSortArgs = plCfg.Args break } } if len(v.queueSort) == 0 { v.queueSort = queueSort v.queueSortArgs = queueSortArgs return nil } if v.queueSort != queueSort {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Jan 06 01:11:19 UTC 2024 - 4K bytes - Viewed (0) -
pkg/scheduler/extender_test.go
expectedResult ScheduleResult expectsErr bool }{ { registerPlugins: []tf.RegisterPluginFunc{ tf.RegisterFilterPlugin("TrueFilter", tf.NewTrueFilterPlugin), tf.RegisterQueueSortPlugin(queuesort.Name, queuesort.New), tf.RegisterBindPlugin(defaultbinder.Name, defaultbinder.New), }, extenders: []tf.FakeExtender{ { ExtenderName: "FakeExtender1",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 16.7K bytes - Viewed (0) -
pkg/scheduler/apis/config/validation/validation_test.go
SchedulerName: "me", Plugins: &config.Plugins{ QueueSort: config.PluginSet{ Enabled: []config.Plugin{{Name: "PrioritySort"}}, }, }, PluginConfig: []config.PluginConfig{{ Name: "PrioritySort", }}, }, { SchedulerName: "other", Plugins: &config.Plugins{ QueueSort: config.PluginSet{ Enabled: []config.Plugin{{Name: "CustomSort"}}, }, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 06:27:01 UTC 2024 - 12.2K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
return true, gotBinding, item.injectBindError }) registerPluginFuncs := append(item.registerPluginFuncs, tf.RegisterQueueSortPlugin(queuesort.Name, queuesort.New), tf.RegisterBindPlugin(defaultbinder.Name, defaultbinder.New), ) ctx, cancel := context.WithCancel(context.Background()) defer cancel() fwk, err := tf.NewFramework(ctx,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/registry.go
nodevolumelimits.CinderName: runtime.FactoryAdapter(fts, nodevolumelimits.NewCinder), interpodaffinity.Name: interpodaffinity.New, queuesort.Name: queuesort.New, defaultbinder.Name: defaultbinder.New, defaultpreemption.Name: runtime.FactoryAdapter(fts, defaultpreemption.New),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 5K bytes - Viewed (0) -
pkg/scheduler/apis/config/v1/default_plugins.go
defaultPlugins.PreEnqueue = mergePluginSet(logger, defaultPlugins.PreEnqueue, customPlugins.PreEnqueue) defaultPlugins.QueueSort = mergePluginSet(logger, defaultPlugins.QueueSort, customPlugins.QueueSort) defaultPlugins.PreFilter = mergePluginSet(logger, defaultPlugins.PreFilter, customPlugins.PreFilter) defaultPlugins.Filter = mergePluginSet(logger, defaultPlugins.Filter, customPlugins.Filter)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 06:27:01 UTC 2024 - 6.7K bytes - Viewed (0) -
pkg/scheduler/framework/preemption/preemption_test.go
} for _, tt := range tests { t.Run(tt.name, func(t *testing.T) { logger, _ := ktesting.NewTestContext(t) registeredPlugins := append([]tf.RegisterPluginFunc{ tf.RegisterQueueSortPlugin(queuesort.Name, queuesort.New)}, tf.RegisterBindPlugin(defaultbinder.Name, defaultbinder.New), ) var objs []runtime.Object for _, p := range append(tt.testPods, tt.initPods...) { objs = append(objs, p) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 18.7K bytes - Viewed (0) -
pkg/scheduler/apis/config/types.go
// should be disabled. // When no enabled or disabled plugin is specified for an extension point, // default plugins for that extension point will be used if there is any. // If a QueueSort plugin is specified, the same QueueSort Plugin and // PluginConfig must be specified for all profiles. Plugins *Plugins // PluginConfig is an optional set of custom plugin arguments for each plugin.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 18:47:23 UTC 2024 - 14.8K bytes - Viewed (0)