- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for fExtenders (0.23 sec)
-
pkg/scheduler/scheduler.go
fExtenders = append(fExtenders, ignorableExtenders...) // If there are any extended resources found from the Extenders, append them to the pluginConfig for each profile. // This should only have an effect on ComponentConfig, where it is possible to configure Extenders and // plugin args (and in which case the extender ignored resources take precedence). if len(ignoredExtendedResources) == 0 {
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/apis/config/validation/validation_test.go
extenderDuplicateManagedResource.Extenders[0].ManagedResources = []config.ExtenderManagedResource{ {Name: "example.com/foo", IgnoredByScheduler: false}, {Name: "example.com/foo", IgnoredByScheduler: false}, } extenderDuplicateBind := validConfig.DeepCopy() extenderDuplicateBind.Extenders[0].BindVerb = "foo" extenderDuplicateBind.Extenders = append(extenderDuplicateBind.Extenders, config.Extender{
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/scheduler_test.go
} // Extenders if len(tc.wantExtenders) != 0 { // Scheduler.Extenders extenders := make([]string, 0, len(s.Extenders)) for _, e := range s.Extenders { extenders = append(extenders, e.Name()) } if diff := cmp.Diff(tc.wantExtenders, extenders); diff != "" { t.Errorf("unexpected extenders (-want, +got):\n%s", diff) }
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/extender_test.go
t.Run(test.name, func(t *testing.T) { client := clientsetfake.NewSimpleClientset() informerFactory := informers.NewSharedInformerFactory(client, 0) var extenders []framework.Extender for ii := range test.extenders { extenders = append(extenders, &test.extenders[ii]) } logger, ctx := ktesting.NewTestContext(t) ctx, cancel := context.WithCancel(ctx) defer cancel()
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.go
} } } return errs } // validateExtenders validates the configured extenders for the Scheduler func validateExtenders(fldPath *field.Path, extenders []config.Extender) []error { var errs []error binders := 0 extenderManagedResources := sets.New[string]() for i, extender := range extenders { path := fldPath.Index(i) if len(extender.PrioritizeVerb) > 0 && extender.Weight <= 0 {
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/schedule_one.go
} } } if len(extenders) != 0 && nodes != nil { // allNodeExtendersScores has all extenders scores for all nodes. // It is keyed with node name. allNodeExtendersScores := make(map[string]*framework.NodePluginScores, len(nodes)) var mu sync.Mutex var wg sync.WaitGroup for i := range extenders { if !extenders[i].IsInterested(pod) { continue } wg.Add(1)
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/runtime/framework.go
{&plugins.Permit, &f.permitPlugins}, {&plugins.PreEnqueue, &f.preEnqueuePlugins}, {&plugins.QueueSort, &f.queueSortPlugins}, } } // Extenders returns the registered extenders. func (f *frameworkImpl) Extenders() []framework.Extender { return f.extenders } type frameworkOptions struct { componentConfigVersion string clientSet clientset.Interface kubeConfig *restclient.Config
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/schedule_one_test.go
t.Fatal(err) } var extenders []framework.Extender for ii := range test.extenders { extenders = append(extenders, &test.extenders[ii]) } sched := &Scheduler{ Cache: cache, nodeInfoSnapshot: snapshot, percentageOfNodesToScore: schedulerapi.DefaultPercentageOfNodesToScore, Extenders: extenders, } sched.applyDefaultHandlers()
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/preemption/preemption.go
nodeStatuses[node] = nodeStatus } return candidates, nodeStatuses, err } // callExtenders calls given <extenders> to select the list of feasible candidates. // We will only check <candidates> with extenders that support preemption. // Extenders which do not support preemption may later prevent preemptor from being scheduled on the nominated
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/apis/config/types.go
// with the "default-scheduler" profile, if present here. Profiles []KubeSchedulerProfile // Extenders are the list of scheduler extenders, each holding the values of how to communicate // with the extender. These extenders are shared by all scheduler profiles. Extenders []Extender // DelayCacheUntilActive specifies when to start caching. If this is true and leader election is enabled,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jan 19 18:47:23 UTC 2024 - 14.8K bytes - Viewed (0)