Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for addAllEventHandlers (0.22 sec)

  1. pkg/scheduler/eventhandlers.go

    			if !handler.HasSynced() {
    				return false, nil
    			}
    		}
    		return true, nil
    	})
    }
    
    // addAllEventHandlers is a helper function used in tests and in Scheduler
    // to add event handlers for various informers.
    func addAllEventHandlers(
    	sched *Scheduler,
    	informerFactory informers.SharedInformerFactory,
    	dynInformerFactory dynamicinformer.DynamicSharedInformerFactory,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 07 21:21:04 UTC 2024
    - 24K bytes
    - Viewed (0)
  2. pkg/scheduler/scheduler.go

    		SchedulingQueue:          podQueue,
    		Profiles:                 profiles,
    		logger:                   logger,
    	}
    	sched.NextPod = podQueue.Pop
    	sched.applyDefaultHandlers()
    
    	if err = addAllEventHandlers(sched, informerFactory, dynInformerFactory, unionedGVKs(queueingHintsPerProfile)); err != nil {
    		return nil, fmt.Errorf("adding event handlers: %w", err)
    	}
    
    	return sched, nil
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  3. pkg/scheduler/eventhandlers_test.go

    				logger:          logger,
    			}
    
    			dynclient := dyfake.NewSimpleDynamicClient(scheme)
    			dynInformerFactory := dynamicinformer.NewDynamicSharedInformerFactory(dynclient, 0)
    
    			if err := addAllEventHandlers(&testSched, informerFactory, dynInformerFactory, tt.gvkMap); err != nil {
    				t.Fatalf("Add event handlers failed, error = %v", err)
    			}
    
    			informerFactory.Start(testSched.StopEverything)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jan 10 14:38:54 UTC 2024
    - 21.5K bytes
    - Viewed (0)
Back to top