Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for PreFilter (0.21 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
Back to top