- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for addPodToCache (0.14 sec)
-
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) -
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)