- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for waitingPods (0.53 sec)
-
pkg/scheduler/framework/runtime/framework.go
// IterateOverWaitingPods acquires a read lock and iterates over the WaitingPods map. func (f *frameworkImpl) IterateOverWaitingPods(callback func(framework.WaitingPod)) { f.waitingPods.iterate(callback) } // GetWaitingPod returns a reference to a WaitingPod given its UID. func (f *frameworkImpl) GetWaitingPod(uid types.UID) framework.WaitingPod { if wp := f.waitingPods.get(uid); wp != nil { return wp }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
pkg/scheduler/scheduler_test.go
wg.Wait() // Ensure that all waitingPods in scheduler can be obtained from any profiles. for _, fwk := range scheduler.Profiles { actualPodNamesInWaitingPods := sets.NewString() fwk.IterateOverWaitingPods(func(pod framework.WaitingPod) { actualPodNamesInWaitingPods.Insert(pod.GetPod().Name) }) // Validate the name of pods in waitingPods matches expectations.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 42K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/waiting_pods_map.go
for _, v := range m.pods { callback(v) } } // waitingPod represents a pod waiting in the permit phase. type waitingPod struct { pod *v1.Pod pendingPlugins map[string]*time.Timer s chan *framework.Status mu sync.RWMutex } var _ framework.WaitingPod = &waitingPod{} // newWaitingPod returns a new waitingPod instance.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 4.5K bytes - Viewed (0) -
pkg/scheduler/scheduler.go
snapshot := internalcache.NewEmptySnapshot() metricsRecorder := metrics.NewMetricsAsyncRecorder(1000, time.Second, stopEverything) // waitingPods holds all the pods that are in the scheduler and waiting in the permit stage waitingPods := frameworkruntime.NewWaitingPodsMap() profiles, err := profile.NewMap(ctx, options.profiles, registry, recorderFactory,
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/kubelet/pod_workers.go
if waitingUID != uid { p.waitingToStartStaticPodsByFullname[fullname] = waitingPods[i:] return false } // we are up next, remove ourselves waitingPods = waitingPods[i+1:] break } if len(waitingPods) != 0 { p.waitingToStartStaticPodsByFullname[fullname] = waitingPods } else { delete(p.waitingToStartStaticPodsByFullname, fullname) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 02 13:22:37 UTC 2024 - 74.8K bytes - Viewed (0) -
pkg/scheduler/framework/interface.go
SnapshotSharedLister() SharedLister // IterateOverWaitingPods acquires a read lock and iterates over the WaitingPods map. IterateOverWaitingPods(callback func(WaitingPod)) // GetWaitingPod returns a waiting pod given its UID. GetWaitingPod(uid types.UID) WaitingPod // RejectWaitingPod rejects a waiting pod given its UID. // The return value indicates if the pod is waiting or not.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.31.md
- Users can traverse all the pods that are in the scheduler and waiting in the permit stage through method `IterateOverWaitingPods`. In other words, all waitingPods in scheduler can be obtained from any profiles. Before this commit, each profile could only obtain waitingPods within that profile. ([#124926](https://github.com/kubernetes/kubernetes/pull/124926), [@kerthcet](https://github.com/kerthcet)) [SIG Scheduling] ### Failing Test
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 20:34:14 UTC 2024 - 60.3K bytes - Viewed (0) -
CHANGELOG/CHANGELOG-1.30.md
- Users can now traverse all the pods that are in the scheduler and waiting in the permit stage through method `IterateOverWaitingPods`. In other words, all waitingPods in scheduler can be obtained from any profiles. Before this commit, each profile could only obtain `waitingPods` within that profile ([#122946](https://github.com/kubernetes/kubernetes/pull/122946), [@NoicFank](https://github.com/NoicFank))
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 04:05:28 UTC 2024 - 253.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go
return true, nil, nil }) logger, ctx := ktesting.NewTestContext(t) ctx, cancel := context.WithCancel(ctx) defer cancel() waitingPods := frameworkruntime.NewWaitingPodsMap() cache := internalcache.New(ctx, time.Duration(0)) for _, pod := range test.pods { cache.AddPod(logger, pod) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 82.8K bytes - Viewed (0) -
pkg/scheduler/schedule_one_test.go
if informerFactory == nil { informerFactory = informers.NewSharedInformerFactory(clientsetfake.NewSimpleClientset(), 0) } schedulingQueue := internalqueue.NewTestQueueWithInformerFactory(ctx, nil, informerFactory) waitingPods := frameworkruntime.NewWaitingPodsMap() fwk, _ := tf.NewFramework( ctx, fns, testSchedulerName, frameworkruntime.WithClientSet(client), frameworkruntime.WithEventRecorder(recorder),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:20:55 UTC 2024 - 128.1K bytes - Viewed (0)