- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for PreEnqueuePlugins (0.19 sec)
-
pkg/scheduler/framework/runtime/framework.go
newPlugins := reflect.Append(plugins, reflect.ValueOf(pg)) plugins.Set(newPlugins) } return nil } // PreEnqueuePlugins returns the registered preEnqueue plugins. func (f *frameworkImpl) PreEnqueuePlugins() []framework.PreEnqueuePlugin { return f.preEnqueuePlugins } // EnqueueExtensions returns the registered reenqueue plugins. func (f *frameworkImpl) EnqueueExtensions() []framework.EnqueueExtensions {
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
// Configured plugins are called at specified points in a scheduling context. type Framework interface { Handle // PreEnqueuePlugins returns the registered preEnqueue plugins. PreEnqueuePlugins() []PreEnqueuePlugin // EnqueueExtensions returns the registered Enqueue extensions. EnqueueExtensions() []EnqueueExtensions
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/scheduler.go
queueingHintsPerProfile := make(internalqueue.QueueingHintMapPerProfile) for profileName, profile := range profiles { preEnqueuePluginMap[profileName] = profile.PreEnqueuePlugins() queueingHintsPerProfile[profileName] = buildQueueingHintMap(profile.EnqueueExtensions()) } podQueue := internalqueue.NewSchedulingQueue( profiles[options.profiles[0].SchedulerName].QueueSortFunc(),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 20.8K bytes - Viewed (0) -
pkg/scheduler/framework/types.go
UnschedulablePlugins sets.Set[string] // PendingPlugins records the plugin names that the Pod failed with Pending status. PendingPlugins sets.Set[string] // Whether the Pod is scheduling gated (by PreEnqueuePlugins) or not. Gated bool } // DeepCopy returns a deep copy of the QueuedPodInfo object. func (pqi *QueuedPodInfo) DeepCopy() *QueuedPodInfo { return &QueuedPodInfo{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 19:28:17 UTC 2024 - 36.7K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework_test.go
f, err := newFrameworkWithQueueSortAndBind(ctx, registry, profile) if err != nil { t.Fatalf("fail to create framework: %s", err) } got := f.PreEnqueuePlugins() if !reflect.DeepEqual(got, tt.want) { t.Errorf("PreEnqueuePlugins(): want %v, but got %v", tt.want, got) } }) } } func TestRunPreScorePlugins(t *testing.T) { tests := []struct { name string
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 103K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
pInfo.Gated = !p.runPreEnqueuePlugins(context.Background(), pInfo) if pInfo.Gated { // Add the Pod to unschedulablePods if it's not passing PreEnqueuePlugins. p.unschedulablePods.addOrUpdate(pInfo) return false, nil } if pInfo.InitialAttemptTimestamp == nil { now := p.clock.Now() pInfo.InitialAttemptTimestamp = &now }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0)