Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for preEnqueuePlugin (0.27 sec)

  1. pkg/scheduler/internal/queue/scheduling_queue_test.go

    			plugins:               []framework.PreEnqueuePlugin{&preEnqueuePlugin{}, &preEnqueuePlugin{}},
    			pod:                   st.MakePod().Name("p").Label("p", "").Obj(),
    			wantUnschedulablePods: 1,
    			wantSuccess:           false,
    		},
    		{
    			name: "preEnqueue plugin registered, pod failed one preEnqueue plugin",
    			plugins: []framework.PreEnqueuePlugin{
    				&preEnqueuePlugin{allowlists: []string{"foo", "bar"}},
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 146.9K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/schedulinggates/scheduling_gates.go

    const Name = names.SchedulingGates
    
    // SchedulingGates checks if a Pod carries .spec.schedulingGates.
    type SchedulingGates struct {
    	enableSchedulingQueueHint bool
    }
    
    var _ framework.PreEnqueuePlugin = &SchedulingGates{}
    var _ framework.EnqueueExtensions = &SchedulingGates{}
    
    func (pl *SchedulingGates) Name() string {
    	return Name
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/schedulinggates/scheduling_gates_test.go

    			_, ctx := ktesting.NewTestContext(t)
    			p, err := New(ctx, nil, nil, feature.Features{})
    			if err != nil {
    				t.Fatalf("Creating plugin: %v", err)
    			}
    
    			got := p.(framework.PreEnqueuePlugin).PreEnqueue(ctx, tt.pod)
    			if diff := cmp.Diff(tt.want, got); diff != "" {
    				t.Errorf("unexpected status (-want, +got):\n%s", diff)
    			}
    		})
    	}
    }
    
    func Test_isSchedulableAfterPodChange(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 3.7K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/runtime/framework_test.go

    	tests := []struct {
    		name    string
    		plugins []framework.Plugin
    		want    []framework.PreEnqueuePlugin
    	}{
    		{
    			name: "no PreEnqueuePlugin registered",
    		},
    		{
    			name: "one PreEnqueuePlugin registered",
    			plugins: []framework.Plugin{
    				&TestPreEnqueuePlugin{},
    			},
    			want: []framework.PreEnqueuePlugin{
    				&TestPreEnqueuePlugin{},
    			},
    		},
    	}
    
    	for _, tt := range tests {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 103K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/interface.go

    	Reject(pluginName, msg string)
    }
    
    // Plugin is the parent type for all the scheduling framework plugins.
    type Plugin interface {
    	Name() string
    }
    
    // PreEnqueuePlugin is an interface that must be implemented by "PreEnqueue" plugins.
    // These plugins are called prior to adding Pods to activeQ.
    // Note: an preEnqueue plugin is expected to be lightweight and efficient, so it's not expected to
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  6. pkg/scheduler/internal/queue/scheduling_queue.go

    	moveRequestCycle int64
    
    	// preEnqueuePluginMap is keyed with profile name, valued with registered preEnqueue plugins.
    	preEnqueuePluginMap map[string][]framework.PreEnqueuePlugin
    	// queueingHintMap is keyed with profile name, valued with registered queueing hint functions.
    	queueingHintMap QueueingHintMapPerProfile
    
    	// closed indicates that the queue is closed.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 61.4K bytes
    - Viewed (0)
  7. pkg/scheduler/scheduler.go

    		return nil, fmt.Errorf("initializing profiles: %v", err)
    	}
    
    	if len(profiles) == 0 {
    		return nil, errors.New("at least one profile is required")
    	}
    
    	preEnqueuePluginMap := make(map[string][]framework.PreEnqueuePlugin)
    	queueingHintsPerProfile := make(internalqueue.QueueingHintMapPerProfile)
    	for profileName, profile := range profiles {
    		preEnqueuePluginMap[profileName] = profile.PreEnqueuePlugins()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:20:55 UTC 2024
    - 20.8K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/runtime/framework.go

    type frameworkImpl struct {
    	registry             Registry
    	snapshotSharedLister framework.SharedLister
    	waitingPods          *waitingPodsMap
    	scorePluginWeight    map[string]int
    	preEnqueuePlugins    []framework.PreEnqueuePlugin
    	enqueueExtensions    []framework.EnqueueExtensions
    	queueSortPlugins     []framework.QueueSortPlugin
    	preFilterPlugins     []framework.PreFilterPlugin
    	filterPlugins        []framework.FilterPlugin
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
  9. pkg/scheduler/framework/plugins/dynamicresources/dynamicresources.go

    	if !ok {
    		return nil, nil
    	}
    	if parameters.GeneratedFrom == nil {
    		return nil, nil
    	}
    	return []string{classParametersReferenceKeyFunc(parameters.GeneratedFrom)}, nil
    }
    
    var _ framework.PreEnqueuePlugin = &dynamicResources{}
    var _ framework.PreFilterPlugin = &dynamicResources{}
    var _ framework.FilterPlugin = &dynamicResources{}
    var _ framework.PostFilterPlugin = &dynamicResources{}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu May 30 15:22:37 UTC 2024
    - 75.9K bytes
    - Viewed (0)
Back to top