- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 28 for PreFilter (0.17 sec)
-
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) -
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) -
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) -
pkg/scheduler/framework/plugins/nodevolumelimits/non_csi_test.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Dec 30 23:00:56 UTC 2023 - 36.8K bytes - Viewed (0) -
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) -
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) -
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) -
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) -
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) -
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)