- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 36 for PreFilter (0.2 sec)
-
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) -
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/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) -
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) -
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) -
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) -
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) -
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/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) -
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)