Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for applyDefaultHandlers (0.15 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
Back to top