Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 36 for PreFilter (0.2 sec)

  1. pkg/scheduler/framework/plugins/podtopologyspread/filtering.go

    )
    
    const preFilterStateKey = "PreFilter" + Name
    
    // preFilterState computed at PreFilter and used at Filter.
    // It combines TpKeyToCriticalPaths and TpPairToMatchNum to represent:
    // (1) critical paths where the least pods are matched on each spread constraint.
    // (2) number of pods matched on each spread constraint.
    // A nil preFilterState denotes it's not set at all (in PreFilter phase);
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Feb 28 10:42:29 UTC 2024
    - 12.4K bytes
    - Viewed (0)
  2. 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)
  3. pkg/scheduler/framework/plugins/volumezone/volume_zone.go

    func (pl *VolumeZone) Name() string {
    	return Name
    }
    
    // PreFilter invoked at the prefilter extension point
    //
    // # It finds the topology of the PersistentVolumes corresponding to the volumes a pod requests
    //
    // Currently, this is only supported with PersistentVolumeClaims,
    // and only looks for the bound PersistentVolume.
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Mar 16 14:13:06 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  4. cmd/kube-scheduler/app/server_test.go

    			wantPlugins: map[string]*config.Plugins{
    				"default-scheduler": func() *config.Plugins {
    					plugins := defaults.ExpandedPluginsV1.DeepCopy()
    					plugins.PreFilter.Enabled = append(plugins.PreFilter.Enabled, config.Plugin{Name: "Foo"})
    					plugins.Filter.Enabled = append(plugins.Filter.Enabled, config.Plugin{Name: "Foo"})
    					return plugins
    				}(),
    			},
    		},
    		{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Apr 24 18:25:29 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  5. pkg/scheduler/framework/interface.go

    }
    
    // PreFilterPlugin is an interface that must be implemented by "PreFilter" plugins.
    // These plugins are called at the beginning of the scheduling cycle.
    type PreFilterPlugin interface {
    	Plugin
    	// PreFilter is called at the beginning of the scheduling cycle. All PreFilter
    	// plugins must return success or the pod will be rejected. PreFilter could optionally
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 35.4K bytes
    - Viewed (0)
  6. pkg/scheduler/framework/plugins/defaultpreemption/default_preemption_test.go

    			}
    			// Register NodeResourceFit as the Filter & PreFilter plugin.
    			registeredPlugins := []tf.RegisterPluginFunc{
    				tf.RegisterQueueSortPlugin(queuesort.Name, queuesort.New),
    				tf.RegisterPluginAsExtensions(noderesources.Name, nodeResourcesFitFunc, "Filter", "PreFilter"),
    				tf.RegisterPluginAsExtensions("test-plugin", newTestPlugin, "PreFilter"),
    				tf.RegisterBindPlugin(defaultbinder.Name, defaultbinder.New),
    			}
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 31 15:52:16 UTC 2024
    - 82.8K bytes
    - Viewed (0)
  7. pkg/scheduler/metrics/metrics.go

    var ExtentionPoints = []string{
    	PreFilter,
    	Filter,
    	PreFilterExtensionAddPod,
    	PreFilterExtensionRemovePod,
    	PostFilter,
    	PreScore,
    	Score,
    	ScoreExtensionNormalize,
    	PreBind,
    	Bind,
    	PostBind,
    	Reserve,
    	Unreserve,
    	Permit,
    }
    
    const (
    	PreFilter                   = "PreFilter"
    	Filter                      = "Filter"
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Sat Apr 27 08:22:53 UTC 2024
    - 11.1K bytes
    - Viewed (0)
  8. 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)
  9. pkg/scheduler/framework/runtime/framework_test.go

    	}{
    		{
    			name: "all PreFilter returned success",
    			plugins: []*TestPlugin{
    				{
    					name: "success1",
    				},
    				{
    					name: "success2",
    				},
    			},
    			wantPreFilterResult: nil,
    			wantStatusCode:      framework.Success,
    		},
    		{
    			name: "one PreFilter plugin returned success, but another PreFilter plugin returned non-success",
    			plugins: []*TestPlugin{
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 103K bytes
    - Viewed (0)
  10. pkg/scheduler/framework/runtime/framework.go

    	if !state.ShouldRecordPluginMetrics() {
    		return pl.PreFilter(ctx, state, pod)
    	}
    	startTime := time.Now()
    	result, status := pl.PreFilter(ctx, state, pod)
    	f.metricsRecorder.ObservePluginDurationAsync(metrics.PreFilter, pl.Name(), status.Code().String(), metrics.SinceInSeconds(startTime))
    	return result, status
    }
    
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri May 17 09:07:27 UTC 2024
    - 60.9K bytes
    - Viewed (0)
Back to top