Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for QueueingHintFn (0.17 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top