- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for PreEnqueuePlugins (0.15 sec)
-
pkg/scheduler/scheduler.go
queueingHintsPerProfile := make(internalqueue.QueueingHintMapPerProfile) for profileName, profile := range profiles { preEnqueuePluginMap[profileName] = profile.PreEnqueuePlugins() queueingHintsPerProfile[profileName] = buildQueueingHintMap(profile.EnqueueExtensions()) } podQueue := internalqueue.NewSchedulingQueue( profiles[options.profiles[0].SchedulerName].QueueSortFunc(),
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/scheduler/framework/types.go
UnschedulablePlugins sets.Set[string] // PendingPlugins records the plugin names that the Pod failed with Pending status. PendingPlugins sets.Set[string] // Whether the Pod is scheduling gated (by PreEnqueuePlugins) or not. Gated bool } // DeepCopy returns a deep copy of the QueuedPodInfo object. func (pqi *QueuedPodInfo) DeepCopy() *QueuedPodInfo { return &QueuedPodInfo{
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 19:28:17 UTC 2024 - 36.7K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
pInfo.Gated = !p.runPreEnqueuePlugins(context.Background(), pInfo) if pInfo.Gated { // Add the Pod to unschedulablePods if it's not passing PreEnqueuePlugins. p.unschedulablePods.addOrUpdate(pInfo) return false, nil } if pInfo.InitialAttemptTimestamp == nil { now := p.clock.Now() pInfo.InitialAttemptTimestamp = &now }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0)