- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for postFilter (0.25 sec)
-
pkg/scheduler/apis/config/v1/default_plugins.go
defaultPlugins.Filter = mergePluginSet(logger, defaultPlugins.Filter, customPlugins.Filter) defaultPlugins.PostFilter = mergePluginSet(logger, defaultPlugins.PostFilter, customPlugins.PostFilter) defaultPlugins.PreScore = mergePluginSet(logger, defaultPlugins.PreScore, customPlugins.PreScore) defaultPlugins.Score = mergePluginSet(logger, defaultPlugins.Score, customPlugins.Score)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 06:27:01 UTC 2024 - 6.7K bytes - Viewed (0) -
pkg/scheduler/framework/interface.go
// other postFilter plugins like preemption would not change anything. // See the comment on PostFilter interface for more details about how PostFilter should handle this status. // Plugins should return Unschedulable if it is possible that the pod can get scheduled // after running other postFilter plugins. // The accompanying status message should explain why the pod is unschedulable.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 31 15:52:16 UTC 2024 - 35.4K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go
initialObjects = testCtx.updateAPIServer(t, initialObjects, tc.prepare.postfilter) result, status := testCtx.p.PostFilter(testCtx.ctx, testCtx.state, tc.pod, nil /* filteredNodeStatusMap not used by plugin */) t.Run("postfilter", func(t *testing.T) { assert.Equal(t, tc.want.postFilterResult, result) testCtx.verify(t, tc.want.postfilter, initialObjects, nil, status) }) } }) } }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 27 07:57:10 UTC 2024 - 61.9K bytes - Viewed (0) -
pkg/scheduler/metrics/metrics.go
PreFilterExtensionAddPod = "PreFilterExtensionAddPod" PreFilterExtensionRemovePod = "PreFilterExtensionRemovePod" PostFilter = "PostFilter" PreScore = "PreScore" Score = "Score" ScoreExtensionNormalize = "ScoreExtensionNormalize" PreBind = "PreBind" Bind = "Bind" PostBind = "PostBind"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Apr 27 08:22:53 UTC 2024 - 11.1K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/defaultpreemption/default_preemption.go
args: *args, podLister: fh.SharedInformerFactory().Core().V1().Pods().Lister(), pdbLister: getPDBLister(fh.SharedInformerFactory()), } return &pl, nil } // PostFilter invoked at the postFilter extension point. func (pl *DefaultPreemption) PostFilter(ctx context.Context, state *framework.CycleState, pod *v1.Pod, m framework.NodeToStatusMap) (*framework.PostFilterResult, *framework.Status) { defer func() {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat Nov 25 19:36:04 UTC 2023 - 12.7K bytes - Viewed (0) -
pkg/scheduler/apis/config/validation/validation.go
"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, "reserve": profile.Plugins.Reserve, "permit": profile.Plugins.Permit,
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/framework/types_test.go
}, // PostFilterMsg will be included. PostFilterMsg: "Error running PostFilter plugin FailedPostFilter", }, wantReasonMsg: "0/3 nodes are available: Node(s) failed PreFilter plugin FalsePreFilter. Error running PostFilter plugin FailedPostFilter", }, { name: "nodes failed one Filter plugin with an empty PostFilterMsg", numAllNodes: 3,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 45.9K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
if !state.ShouldRecordPluginMetrics() { return pl.PostFilter(ctx, state, pod, filteredNodeStatusMap) } startTime := time.Now() r, s := pl.PostFilter(ctx, state, pod, filteredNodeStatusMap) f.metricsRecorder.ObservePluginDurationAsync(metrics.PostFilter, pl.Name(), s.Code().String(), metrics.SinceInSeconds(startTime)) return r, s }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 60.9K bytes - Viewed (0) -
pkg/scheduler/apis/config/testing/defaults/defaults.go
{Name: names.NodeVolumeLimits}, {Name: names.VolumeBinding}, {Name: names.VolumeZone}, {Name: names.PodTopologySpread}, {Name: names.InterPodAffinity}, }, }, PostFilter: config.PluginSet{ Enabled: []config.Plugin{ {Name: names.DefaultPreemption}, }, }, PreScore: config.PluginSet{ Enabled: []config.Plugin{ {Name: names.TaintToleration},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 06:27:01 UTC 2024 - 5.6K bytes - Viewed (0) -
pkg/scheduler/apis/config/types.go
PreFilter PluginSet // Filter is a list of plugins that should be invoked when filtering out nodes that cannot run the Pod. Filter PluginSet // PostFilter is a list of plugins that are invoked after filtering phase, but only when no feasible nodes were found for the pod. PostFilter PluginSet // PreScore is a list of plugins that are invoked before scoring. PreScore 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)