Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 28 of 28 for PreFilter (0.36 sec)

  1. pkg/scheduler/framework/plugins/nodeaffinity/node_affinity_test.go

    			name: "Matches node selector correctly even if PreFilter is not called",
    			pod: &v1.Pod{
    				Spec: v1.PodSpec{
    					NodeSelector: map[string]string{
    						"foo": "bar",
    					},
    				},
    			},
    			labels: map[string]string{
    				"foo": "bar",
    				"baz": "blah",
    			},
    			runPreFilter: false,
    		},
    		{
    			name: "Matches node affinity correctly even if PreFilter is not called",
    			pod: &v1.Pod{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Dec 18 12:00:10 UTC 2023
    - 38.7K bytes
    - Viewed (0)
  2. pkg/scheduler/apis/config/v1/zz_generated.conversion.go

    		return err
    	}
    	if err := Convert_v1_PluginSet_To_config_PluginSet(&in.QueueSort, &out.QueueSort, s); err != nil {
    		return err
    	}
    	if err := Convert_v1_PluginSet_To_config_PluginSet(&in.PreFilter, &out.PreFilter, s); err != nil {
    		return err
    	}
    	if err := Convert_v1_PluginSet_To_config_PluginSet(&in.Filter, &out.Filter, s); err != nil {
    		return err
    	}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jan 19 18:47:23 UTC 2024
    - 46.9K bytes
    - Viewed (0)
  3. pkg/scheduler/framework/preemption/preemption_test.go

    			)
    			if err != nil {
    				t.Fatal(err)
    			}
    
    			state := framework.NewCycleState()
    			// Some tests rely on PreFilter plugin to compute its CycleState.
    			if _, status := fwk.RunPreFilterPlugins(ctx, state, tt.pod); !status.IsSuccess() {
    				t.Errorf("Unexpected PreFilter Status: %v", status)
    			}
    			nodeInfos, err := snapshot.NodeInfos().List()
    			if err != nil {
    				t.Fatal(err)
    			}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 18.7K bytes
    - Viewed (0)
  4. cmd/kube-scheduler/app/options/options_test.go

    					{
    						SchedulerName: "high-throughput-profile",
    						Plugins: &kubeschedulerconfig.Plugins{
    							QueueSort:  defaults.PluginsV1.QueueSort,
    							PreFilter:  defaults.PluginsV1.PreFilter,
    							Filter:     defaults.PluginsV1.Filter,
    							PostFilter: defaults.PluginsV1.PostFilter,
    							PreScore: kubeschedulerconfig.PluginSet{
    								Enabled: []kubeschedulerconfig.Plugin{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 13 07:42:19 UTC 2023
    - 30.3K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/plugins/nodevolumelimits/csi_test.go

    				translator:           csiTranslator,
    			}
    			_, ctx := ktesting.NewTestContext(t)
    			_, gotPreFilterStatus := p.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 {
    				gotStatus := p.Filter(ctx, nil, test.newPod, node)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 14 18:07:11 UTC 2024
    - 28.6K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/interpodaffinity/scoring.go

    	state := &preScoreState{
    		topologyScore: make(map[string]map[string]int64),
    	}
    
    	if state.podInfo, err = framework.NewPodInfo(pod); err != nil {
    		// Ideally we never reach here, because errors will be caught by PreFilter
    		return framework.AsStatus(fmt.Errorf("failed to parse pod: %w", err))
    	}
    
    	for i := range state.podInfo.PreferredAffinityTerms {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Dec 15 03:30:06 UTC 2023
    - 10.5K bytes
    - Viewed (0)
  7. pkg/scheduler/schedule_one.go

    		for _, n := range allNodes {
    			diagnosis.NodeToStatusMap[n.Node().Name] = s
    		}
    
    		// Record the messages from PreFilter in Diagnosis.PreFilterMsg.
    		msg := s.Message()
    		diagnosis.PreFilterMsg = msg
    		logger.V(5).Info("Status after running PreFilter plugins for pod", "pod", klog.KObj(pod), "status", msg)
    		diagnosis.AddPluginStatus(s)
    		return nil, diagnosis, nil
    	}
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Jun 06 13:28:08 UTC 2024
    - 43.4K bytes
    - Viewed (0)
  8. pkg/scheduler/framework/preemption/preemption.go

    // Note: We could possibly check if the nominated lower priority pods still fit
    // and return those that no longer fit, but that would require lots of
    // manipulation of NodeInfo and PreFilter state per nominated pod. It may not be
    // worth the complexity, especially because we generally expect to have a very
    // small number of nominated pods per node.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 25.1K bytes
    - Viewed (0)
Back to top