Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 28 for PreFilter (0.17 sec)

  1. pkg/scheduler/framework/plugins/volumebinding/volume_binding.go

    				return hasPVC, err
    			}
    		}
    	}
    	return hasPVC, nil
    }
    
    // PreFilter invoked at the prefilter extension point to check if pod has all
    // immediate PVCs bound. If not all immediate PVCs are bound, an
    // UnschedulableAndUnresolvable is returned.
    func (pl *VolumeBinding) PreFilter(ctx context.Context, state *framework.CycleState, pod *v1.Pod) (*framework.PreFilterResult, *framework.Status) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 16.4K bytes
    - Viewed (0)
  2. pkg/scheduler/framework/plugins/nodeports/node_ports_test.go

    			_, preFilterStatus := p.(framework.PreFilterPlugin).PreFilter(ctx, cycleState, test.pod)
    			if diff := cmp.Diff(test.wantPreFilterStatus, preFilterStatus); diff != "" {
    				t.Errorf("preFilter status does not match (-want,+got): %s", diff)
    			}
    			if preFilterStatus.IsSkip() {
    				return
    			}
    			if !preFilterStatus.IsSuccess() {
    				t.Errorf("prefilter failed with status: %v", preFilterStatus)
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Oct 19 11:02:11 UTC 2023
    - 10.1K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/plugins/noderesources/fit.go

    	reqs := resource.PodRequests(pod, resource.PodResourcesOptions{})
    	result := &preFilterState{}
    	result.SetMaxResource(reqs)
    	return result
    }
    
    // PreFilter invoked at the prefilter extension point.
    func (f *Fit) PreFilter(ctx context.Context, cycleState *framework.CycleState, pod *v1.Pod) (*framework.PreFilterResult, *framework.Status) {
    	if !f.enableSidecarContainers && hasRestartableInitContainer(pod) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 13:26:09 UTC 2024
    - 20.2K bytes
    - Viewed (0)
  4. pkg/scheduler/framework/plugins/nodevolumelimits/non_csi_test.go

    			_, gotPreFilterStatus := p.(*nonCSILimits).PreFilter(ctx, nil, test.newPod)
    			if diff := cmp.Diff(test.wantPreFilterStatus, gotPreFilterStatus); diff != "" {
    				t.Errorf("PreFilter status does not match (-want, +got): %s", diff)
    			}
    
    			if gotPreFilterStatus.Code() != framework.Skip {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Dec 30 23:00:56 UTC 2023
    - 36.8K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/types.go

    	preFilterMsg := f.Diagnosis.PreFilterMsg
    	if preFilterMsg != "" {
    		// PreFilter plugin returns unschedulable.
    		// Add the messages from PreFilter plugins to reasonMsg.
    		reasonMsg += fmt.Sprintf(" %v.", preFilterMsg)
    	}
    
    	if preFilterMsg == "" {
    		// the scheduling cycle went through PreFilter extension point successfully.
    		//
    		// When the prefilter plugin returns unschedulable,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Jun 12 19:28:17 UTC 2024
    - 36.7K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/nodevolumelimits/csi.go

    	return framework.QueueSkip, nil
    }
    
    // PreFilter invoked at the prefilter extension point
    //
    // If the pod haven't those types of volumes, we'll skip the Filter phase
    func (pl *CSILimits) PreFilter(ctx context.Context, _ *framework.CycleState, pod *v1.Pod) (*framework.PreFilterResult, *framework.Status) {
    	volumes := pod.Spec.Volumes
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 18:07:11 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  7. pkg/scheduler/framework/plugins/nodevolumelimits/non_csi.go

    		{Event: framework.ClusterEvent{Resource: framework.PersistentVolumeClaim, ActionType: framework.Add}},
    	}
    }
    
    // PreFilter invoked at the prefilter extension point
    //
    // If the pod haven't those types of volumes, we'll skip the Filter phase
    func (pl *nonCSILimits) PreFilter(ctx context.Context, _ *framework.CycleState, pod *v1.Pod) (*framework.PreFilterResult, *framework.Status) {
    	volumes := pod.Spec.Volumes
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Dec 30 23:00:56 UTC 2023
    - 19.6K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/plugins/volumebinding/volume_binding_test.go

    			t.Logf("Verify: call PreFilter and check status")
    			gotPreFilterResult, gotPreFilterStatus := p.PreFilter(ctx, state, item.pod)
    			assert.Equal(t, item.wantPreFilterStatus, gotPreFilterStatus)
    			assert.Equal(t, item.wantPreFilterResult, gotPreFilterResult)
    
    			if !gotPreFilterStatus.IsSuccess() {
    				// scheduler framework will skip Filter if PreFilter fails
    				return
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 32K bytes
    - Viewed (0)
  9. pkg/scheduler/apis/config/validation/validation.go

    	}
    
    	if profile.Plugins != nil {
    		stagesToPluginSet := map[string]config.PluginSet{
    			"preEnqueue": profile.Plugins.PreEnqueue,
    			"queueSort":  profile.Plugins.QueueSort,
    			"preFilter":  profile.Plugins.PreFilter,
    			"filter":     profile.Plugins.Filter,
    			"postFilter": profile.Plugins.PostFilter,
    			"preScore":   profile.Plugins.PreScore,
    			"score":      profile.Plugins.Score,
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Apr 25 06:27:01 UTC 2024
    - 11.5K bytes
    - Viewed (0)
  10. pkg/scheduler/apis/config/types.go

    	PreEnqueue PluginSet
    
    	// QueueSort is a list of plugins that should be invoked when sorting pods in the scheduling queue.
    	QueueSort PluginSet
    
    	// PreFilter is a list of plugins that should be invoked at "PreFilter" extension point of the scheduling framework.
    	PreFilter PluginSet
    
    	// Filter is a list of plugins that should be invoked when filtering out nodes that cannot run the Pod.
    	Filter PluginSet
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 18:47:23 UTC 2024
    - 14.8K bytes
    - Viewed (0)
Back to top