- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for applyDefaultHandlers (0.23 sec)
-
pkg/scheduler/scheduler.go
registeredHandlers []cache.ResourceEventHandlerRegistration } func (sched *Scheduler) applyDefaultHandlers() { sched.SchedulePod = sched.schedulePod sched.FailureHandler = sched.handleSchedulingFailure } type schedulerOptions struct { componentConfigVersion string
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/extender_test.go
nodeInfoSnapshot: emptySnapshot, percentageOfNodesToScore: schedulerapi.DefaultPercentageOfNodesToScore, Extenders: extenders, logger: logger, } sched.applyDefaultHandlers() podIgnored := &v1.Pod{} result, err := sched.SchedulePod(ctx, fwk, framework.NewCycleState(), podIgnored) if test.expectsErr { if err == nil {
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/schedule_one_test.go
Cache: cache, nodeInfoSnapshot: snapshot, percentageOfNodesToScore: schedulerapi.DefaultPercentageOfNodesToScore, Extenders: extenders, } sched.applyDefaultHandlers() informerFactory.Start(ctx.Done()) informerFactory.WaitForCacheSync(ctx.Done()) result, err := sched.SchedulePod(ctx, fwk, framework.NewCycleState(), test.pod) if err != test.wErr {
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/scheduler_test.go
Cache: cache, client: client, StopEverything: ctx.Done(), SchedulingQueue: queue, Profiles: profile.Map{testSchedulerName: fwk}, logger: logger, } s.applyDefaultHandlers() return s, fwk, nil } func TestInitPluginsWithIndexers(t *testing.T) { tests := []struct { name string // the plugin registration ordering must not matter, being map traversal random
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 42K bytes - Viewed (0)