- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for QueueingHintFn (0.17 sec)
-
pkg/scheduler/scheduler_test.go
{PluginName: filterWithoutEnqueueExtensions, QueueingHintFn: defaultQueueingHintFn}, }, {Resource: framework.Node, ActionType: framework.All}: { {PluginName: filterWithoutEnqueueExtensions, QueueingHintFn: defaultQueueingHintFn}, }, {Resource: framework.CSINode, ActionType: framework.All}: { {PluginName: filterWithoutEnqueueExtensions, QueueingHintFn: defaultQueueingHintFn}, },
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/internal/queue/scheduling_queue_test.go
PvAdd: { { PluginName: "fooPlugin1", QueueingHintFn: queueHintReturnQueue, }, }, NodeAdd: { { PluginName: "fooPlugin1", QueueingHintFn: queueHintReturnQueue, }, }, PvcAdd: { { PluginName: "fooPlugin1", QueueingHintFn: queueHintReturnQueue, }, }, }, }, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 146.9K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeports/node_ports.go
return []framework.ClusterEventWithHint{ // Due to immutable fields `spec.containers[*].ports`, pod update events are ignored. {Event: framework.ClusterEvent{Resource: framework.Pod, ActionType: framework.Delete}, QueueingHintFn: pl.isSchedulableAfterPodDeleted}, // TODO(#110175): Ideally, it's supposed to register only NodeCreated, because NodeUpdated event never means to have any free ports for the Pod.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 10:53:29 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/scheduler/scheduler.go
// So, we can just ignore such EventsToRegister here. registerNodeAdded := false registerNodeTaintUpdated := false for _, event := range events { fn := event.QueueingHintFn if fn == nil || !utilfeature.DefaultFeatureGate.Enabled(features.SchedulerQueueingHints) { fn = defaultQueueingHintFn } if event.Event.Resource == framework.Node {
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/plugins/podtopologyspread/plugin.go
// deleting an existing Pod may make it schedulable. {Event: framework.ClusterEvent{Resource: framework.Pod, ActionType: framework.All}, QueueingHintFn: pl.isSchedulableAfterPodChange}, // Node add|delete|update maybe lead an topology key changed, // and make these pod in scheduling schedulable or unschedulable. // // A note about UpdateNodeTaint event:
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Mar 16 14:13:06 UTC 2024 - 12.7K bytes - Viewed (0) -
pkg/scheduler/framework/types.go
Event ClusterEvent // QueueingHintFn is executed for the plugin rejected by this plugin when the above Event happens, // and filters out events to reduce useless retry of Pod's scheduling. // It's an optional field. If not set, // the scheduling of Pods will be always retried with backoff when this Event happens. // (the same as Queue) QueueingHintFn QueueingHintFn }
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/framework/plugins/tainttoleration/taint_toleration.go
clusterEventWithHint := []framework.ClusterEventWithHint{ {Event: framework.ClusterEvent{Resource: framework.Node, ActionType: framework.Add | framework.Update}, QueueingHintFn: pl.isSchedulableAfterNodeChange}, } if !pl.enableSchedulingQueueHint { return clusterEventWithHint } // When the QueueingHint feature is enabled, // the scheduling queue uses Pod/Update Queueing Hint
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 9.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/schedulinggates/scheduling_gates.go
return []framework.ClusterEventWithHint{ // Pods can be more schedulable once it's gates are removed {Event: framework.ClusterEvent{Resource: framework.Pod, ActionType: framework.Update}, QueueingHintFn: pl.isSchedulableAfterPodChange}, } } // New initializes a new plugin and returns it. func New(_ context.Context, _ runtime.Object, _ framework.Handle, fts feature.Features) (framework.Plugin, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 3.2K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/nodeunschedulable/node_unschedulable.go
func (pl *NodeUnschedulable) EventsToRegister() []framework.ClusterEventWithHint { return []framework.ClusterEventWithHint{ {Event: framework.ClusterEvent{Resource: framework.Node, ActionType: framework.Add | framework.Update}, QueueingHintFn: pl.isSchedulableAfterNodeChange}, } } // isSchedulableAfterNodeChange is invoked for all node events reported by // an informer. It checks whether that change made a previously unschedulable // pod schedulable.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 16 12:50:11 UTC 2023 - 3.9K bytes - Viewed (0) -
pkg/scheduler/internal/queue/scheduling_queue.go
isSchedulingQueueHintEnabled bool } // QueueingHintFunction is the wrapper of QueueingHintFn that has PluginName. type QueueingHintFunction struct { PluginName string QueueingHintFn framework.QueueingHintFn } // clusterEvent has the event and involved objects. type clusterEvent struct { event framework.ClusterEvent
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 12 13:26:09 UTC 2024 - 61.4K bytes - Viewed (0)