Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for addPodToCache (0.14 sec)

  1. pkg/scheduler/eventhandlers.go

    	if fwk.RejectWaitingPod(pod.UID) {
    		sched.SchedulingQueue.MoveAllToActiveOrBackoffQueue(logger, queue.AssignedPodDelete, pod, nil, nil)
    	}
    }
    
    func (sched *Scheduler) addPodToCache(obj interface{}) {
    	logger := sched.logger
    	pod, ok := obj.(*v1.Pod)
    	if !ok {
    		logger.Error(nil, "Cannot convert to *v1.Pod", "obj", obj)
    		return
    	}
    
    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/eventhandlers_test.go

    			defer cancel()
    			sched := &Scheduler{
    				Cache:           cache.New(ctx, ttl),
    				SchedulingQueue: queue.NewTestQueue(ctx, nil),
    				logger:          logger,
    			}
    			sched.addPodToCache(tt.oldObj)
    			sched.updatePodInCache(tt.oldObj, tt.newObj)
    
    			if tt.oldObj.(*v1.Pod).UID != tt.newObj.(*v1.Pod).UID {
    				if pod, err := sched.Cache.GetPod(tt.oldObj.(*v1.Pod)); err == nil {
    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