- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for preEnqueuePlugin (0.27 sec)
-
pkg/scheduler/internal/queue/scheduling_queue_test.go
plugins: []framework.PreEnqueuePlugin{&preEnqueuePlugin{}, &preEnqueuePlugin{}}, pod: st.MakePod().Name("p").Label("p", "").Obj(), wantUnschedulablePods: 1, wantSuccess: false, }, { name: "preEnqueue plugin registered, pod failed one preEnqueue plugin", plugins: []framework.PreEnqueuePlugin{ &preEnqueuePlugin{allowlists: []string{"foo", "bar"}},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/schedulinggates/scheduling_gates.go
const Name = names.SchedulingGates // SchedulingGates checks if a Pod carries .spec.schedulingGates. type SchedulingGates struct { enableSchedulingQueueHint bool } var _ framework.PreEnqueuePlugin = &SchedulingGates{} var _ framework.EnqueueExtensions = &SchedulingGates{} func (pl *SchedulingGates) Name() string { return Name }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 3.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/schedulinggates/scheduling_gates_test.go
_, ctx := ktesting.NewTestContext(t) p, err := New(ctx, nil, nil, feature.Features{}) if err != nil { t.Fatalf("Creating plugin: %v", err) } got := p.(framework.PreEnqueuePlugin).PreEnqueue(ctx, tt.pod) if diff := cmp.Diff(tt.want, got); diff != "" { t.Errorf("unexpected status (-want, +got):\n%s", diff) } }) } } func Test_isSchedulableAfterPodChange(t *testing.T) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 3.7K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework_test.go
tests := []struct { name string plugins []framework.Plugin want []framework.PreEnqueuePlugin }{ { name: "no PreEnqueuePlugin registered", }, { name: "one PreEnqueuePlugin registered", plugins: []framework.Plugin{ &TestPreEnqueuePlugin{}, }, want: []framework.PreEnqueuePlugin{ &TestPreEnqueuePlugin{}, }, }, } for _, tt := range tests {
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/framework/interface.go
Reject(pluginName, msg string) } // Plugin is the parent type for all the scheduling framework plugins. type Plugin interface { Name() string } // PreEnqueuePlugin is an interface that must be implemented by "PreEnqueue" plugins. // These plugins are called prior to adding Pods to activeQ. // Note: an preEnqueue plugin is expected to be lightweight and efficient, so it's not expected to
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/internal/queue/scheduling_queue.go
moveRequestCycle int64 // preEnqueuePluginMap is keyed with profile name, valued with registered preEnqueue plugins. preEnqueuePluginMap map[string][]framework.PreEnqueuePlugin // queueingHintMap is keyed with profile name, valued with registered queueing hint functions. queueingHintMap QueueingHintMapPerProfile // closed indicates that the queue is closed.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0) -
pkg/scheduler/scheduler.go
return nil, fmt.Errorf("initializing profiles: %v", err) } if len(profiles) == 0 { return nil, errors.New("at least one profile is required") } preEnqueuePluginMap := make(map[string][]framework.PreEnqueuePlugin) queueingHintsPerProfile := make(internalqueue.QueueingHintMapPerProfile) for profileName, profile := range profiles { preEnqueuePluginMap[profileName] = profile.PreEnqueuePlugins()
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/runtime/framework.go
type frameworkImpl struct { registry Registry snapshotSharedLister framework.SharedLister waitingPods *waitingPodsMap scorePluginWeight map[string]int preEnqueuePlugins []framework.PreEnqueuePlugin enqueueExtensions []framework.EnqueueExtensions queueSortPlugins []framework.QueueSortPlugin preFilterPlugins []framework.PreFilterPlugin filterPlugins []framework.FilterPlugin
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/dynamicresources/dynamicresources.go
if !ok { return nil, nil } if parameters.GeneratedFrom == nil { return nil, nil } return []string{classParametersReferenceKeyFunc(parameters.GeneratedFrom)}, nil } var _ framework.PreEnqueuePlugin = &dynamicResources{} var _ framework.PreFilterPlugin = &dynamicResources{} var _ framework.FilterPlugin = &dynamicResources{} var _ framework.PostFilterPlugin = &dynamicResources{}
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 15:22:37 UTC 2024 - 75.9K bytes - Viewed (0)