- Sort Score
- Result 10 results
- Languages All
Results 21 - 28 of 28 for PreFilter (0.36 sec)
-
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) -
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) -
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) -
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) -
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) -
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) -
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) -
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)