- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 57 for postbind (0.23 sec)
-
pkg/scheduler/apis/config/v1/default_plugins.go
defaultPlugins.PreBind = mergePluginSet(logger, defaultPlugins.PreBind, customPlugins.PreBind) defaultPlugins.Bind = mergePluginSet(logger, defaultPlugins.Bind, customPlugins.Bind) defaultPlugins.PostBind = mergePluginSet(logger, defaultPlugins.PostBind, customPlugins.PostBind) return defaultPlugins } type pluginIndex struct { index int plugin v1.Plugin }
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/metrics/metrics.go
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/testing/framework/framework_helpers.go
case "Bind": return &plugins.Bind case "Reserve": return &plugins.Reserve case "Permit": return &plugins.Permit case "PreBind": return &plugins.PreBind case "PostBind": return &plugins.PostBind default: return nil } } // BuildNodeInfos build NodeInfo slice from a v1.Node slice func BuildNodeInfos(nodes []*v1.Node) []*framework.NodeInfo {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 6.3K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/dynamicresources_test.go
initialObjects = testCtx.listAll(t) initialObjects = testCtx.updateAPIServer(t, initialObjects, tc.prepare.postbind) testCtx.p.PostBind(testCtx.ctx, testCtx.state, tc.pod, selectedNode.Node().Name) t.Run("postbind", func(t *testing.T) { testCtx.verify(t, tc.want.postbind, initialObjects, nil, nil) }) } } } else { initialObjects = testCtx.listAll(t)
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/apis/config/validation/validation.go
"reserve": profile.Plugins.Reserve, "permit": profile.Plugins.Permit, "preBind": profile.Plugins.PreBind, "bind": profile.Plugins.Bind, "postBind": profile.Plugins.PostBind, } pluginsPath := path.Child("plugins") for s, p := range stagesToPluginSet { errs = append(errs, validatePluginSetForInvalidPlugins( pluginsPath.Child(s), apiVersion, p)...) }
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
// The scheduler call these plugins in order. Scheduler skips the rest of these plugins as soon as one returns success. Bind PluginSet // PostBind is a list of plugins that should be invoked after a pod is successfully bound. PostBind PluginSet // MultiPoint is a simplified config field for enabling plugins for all valid extension points MultiPoint 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) -
pkg/scheduler/framework/runtime/framework_test.go
wantExtensionPoint: "Bind", wantStatus: framework.Success, }, { name: "PostBind - Success", action: func(f framework.Framework) { f.RunPostBindPlugins(context.Background(), state, pod, "") }, wantExtensionPoint: "PostBind", wantStatus: framework.Success, }, { name: "Permit - Success",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri May 17 09:07:27 UTC 2024 - 103K bytes - Viewed (0) -
pkg/scheduler/framework/runtime/framework.go
if !state.ShouldRecordPluginMetrics() { pl.PostBind(ctx, state, pod, nodeName) return } startTime := time.Now() pl.PostBind(ctx, state, pod, nodeName) f.metricsRecorder.ObservePluginDurationAsync(metrics.PostBind, pl.Name(), framework.Success.String(), metrics.SinceInSeconds(startTime)) }
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/framework/interface.go
PreBind(ctx context.Context, state *CycleState, p *v1.Pod, nodeName string) *Status } // PostBindPlugin is an interface that must be implemented by "PostBind" plugins. // These plugins are called after a pod is successfully bound to a node. type PostBindPlugin interface { Plugin // PostBind is called after a pod is successfully bound. These plugins are // informational. A common application of this extension point is for cleaning
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/apis/config/v1/defaults.go
if p == nil { return nil } extensions := []configv1.PluginSet{ p.MultiPoint, p.PreFilter, p.Filter, p.PostFilter, p.Reserve, p.PreScore, p.Score, p.PreBind, p.Bind, p.PostBind, p.Permit, p.PreEnqueue, p.QueueSort, } n := sets.New[string]() for _, e := range extensions { for _, pg := range e.Enabled { n.Insert(pg.Name) } } return sets.List(n) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 13 07:42:19 UTC 2023 - 7.2K bytes - Viewed (0)