- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for PreFilter (0.21 sec)
-
pkg/scheduler/framework/plugins/nodeports/node_ports.go
if container.Ports[k].HostPort <= 0 { continue } ports = append(ports, &container.Ports[k]) } } } return ports } // PreFilter invoked at the prefilter extension point. func (pl *NodePorts) PreFilter(ctx context.Context, cycleState *framework.CycleState, pod *v1.Pod) (*framework.PreFilterResult, *framework.Status) { s := getContainerPorts(pod) // Skip if a pod has no ports.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 26 10:53:29 UTC 2024 - 7.5K bytes - Viewed (0) -
pkg/scheduler/testing/framework/framework_helpers.go
} // RegisterPreFilterPlugin returns a function to register a PreFilter Plugin to a given registry. func RegisterPreFilterPlugin(pluginName string, pluginNewFunc runtime.PluginFactory) RegisterPluginFunc { return RegisterPluginAsExtensions(pluginName, pluginNewFunc, "PreFilter") } // RegisterFilterPlugin returns a function to register a Filter Plugin to a given registry.
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/runtime/instrumented_plugins.go
} var _ framework.PreFilterPlugin = &instrumentedPreFilterPlugin{} func (p *instrumentedPreFilterPlugin) PreFilter(ctx context.Context, state *framework.CycleState, pod *v1.Pod) (*framework.PreFilterResult, *framework.Status) { result, status := p.PreFilterPlugin.PreFilter(ctx, state, pod) if !status.IsSkip() { p.metric.Inc() } return result, status } type instrumentedPreScorePlugin struct {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Dec 15 03:30:06 UTC 2023 - 2.4K bytes - Viewed (0) -
pkg/scheduler/apis/config/v1/default_plugins.go
defaultPlugins.QueueSort = mergePluginSet(logger, defaultPlugins.QueueSort, customPlugins.QueueSort) defaultPlugins.PreFilter = mergePluginSet(logger, defaultPlugins.PreFilter, customPlugins.PreFilter) defaultPlugins.Filter = mergePluginSet(logger, defaultPlugins.Filter, customPlugins.Filter) defaultPlugins.PostFilter = mergePluginSet(logger, defaultPlugins.PostFilter, customPlugins.PostFilter)
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/apis/config/types_test.go
}{ { name: "empty", }, { name: "with duplicates", plugins: &Plugins{ Filter: PluginSet{ Enabled: []Plugin{ {Name: "CustomFilter"}, }, }, PreFilter: PluginSet{ Enabled: []Plugin{ {Name: "CustomFilter"}, }, }, Score: PluginSet{ Enabled: []Plugin{ {Name: "CustomScore"}, }, }, },
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jun 16 14:15:29 UTC 2021 - 1.4K bytes - Viewed (0) -
pkg/scheduler/testing/framework/fake_plugins.go
Status *framework.Status name string } // Name returns name of the plugin. func (pl *FakePreFilterPlugin) Name() string { return pl.name } // PreFilter invoked at the PreFilter extension point. func (pl *FakePreFilterPlugin) PreFilter(_ context.Context, _ *framework.CycleState, pod *v1.Pod) (*framework.PreFilterResult, *framework.Status) { return pl.Result, pl.Status }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 26 19:07:19 UTC 2024 - 9.5K bytes - Viewed (0) -
pkg/scheduler/framework/cycle_state.go
// It is the recommended pattern used in all in-tree plugins - plugin-specific state is written once in PreFilter/PreScore and afterward read many times in Filter/Score. type CycleState struct { // storage is keyed with StateKey, and valued with StateData. storage sync.Map
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 18 06:48:20 UTC 2023 - 4K bytes - Viewed (0) -
pkg/scheduler/apis/config/testing/defaults/defaults.go
PreEnqueue: config.PluginSet{ Enabled: []config.Plugin{ {Name: names.SchedulingGates}, }, }, QueueSort: config.PluginSet{ Enabled: []config.Plugin{ {Name: names.PrioritySort}, }, }, PreFilter: config.PluginSet{ Enabled: []config.Plugin{ {Name: names.NodeAffinity}, {Name: names.NodePorts}, {Name: names.NodeResourcesFit}, {Name: names.VolumeRestrictions}, {Name: names.NodeVolumeLimits},
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/v1/defaults.go
return RegisterDefaults(scheme) } func pluginsNames(p *configv1.Plugins) []string { 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]()
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 13 07:42:19 UTC 2023 - 7.2K bytes - Viewed (0)