const maxTimeout … type frameworkImpl … type extensionPoint … func (f *frameworkImpl) getExtensionPoints(plugins *config.Plugins) []extensionPoint { … } // Extenders returns the registered extenders. func (f *frameworkImpl) Extenders() []framework.Extender { … } type frameworkOptions … type Option … // WithComponentConfigVersion sets the component config version to the // KubeSchedulerConfiguration version used. The string should be the full // scheme group/version of the external type we converted from (for example // "kubescheduler.config.k8s.io/v1") func WithComponentConfigVersion(componentConfigVersion string) Option { … } // WithClientSet sets clientSet for the scheduling frameworkImpl. func WithClientSet(clientSet clientset.Interface) Option { … } // WithKubeConfig sets kubeConfig for the scheduling frameworkImpl. func WithKubeConfig(kubeConfig *restclient.Config) Option { … } // WithEventRecorder sets clientSet for the scheduling frameworkImpl. func WithEventRecorder(recorder events.EventRecorder) Option { … } // WithInformerFactory sets informer factory for the scheduling frameworkImpl. func WithInformerFactory(informerFactory informers.SharedInformerFactory) Option { … } // WithResourceClaimCache sets the resource claim cache for the scheduling frameworkImpl. func WithResourceClaimCache(resourceClaimCache *assumecache.AssumeCache) Option { … } // WithSnapshotSharedLister sets the SharedLister of the snapshot. func WithSnapshotSharedLister(snapshotSharedLister framework.SharedLister) Option { … } // WithPodNominator sets podNominator for the scheduling frameworkImpl. func WithPodNominator(nominator framework.PodNominator) Option { … } // WithExtenders sets extenders for the scheduling frameworkImpl. func WithExtenders(extenders []framework.Extender) Option { … } // WithParallelism sets parallelism for the scheduling frameworkImpl. func WithParallelism(parallelism int) Option { … } type CaptureProfile … // WithCaptureProfile sets a callback to capture the finalized profile. func WithCaptureProfile(c CaptureProfile) Option { … } // WithMetricsRecorder sets metrics recorder for the scheduling frameworkImpl. func WithMetricsRecorder(r *metrics.MetricAsyncRecorder) Option { … } // WithWaitingPods sets waitingPods for the scheduling frameworkImpl. func WithWaitingPods(wp *waitingPodsMap) Option { … } // WithLogger overrides the default logger from k8s.io/klog. func WithLogger(logger klog.Logger) Option { … } // defaultFrameworkOptions are applied when no option corresponding to those fields exist. func defaultFrameworkOptions(stopCh <-chan struct{ … } var _ … // NewFramework initializes plugins given the configuration and the registry. func NewFramework(ctx context.Context, r Registry, profile *config.KubeSchedulerProfile, opts ...Option) (framework.Framework, error) { … } // setInstrumentedPlugins initializes instrumented plugins from current plugins that frameworkImpl has. func (f *frameworkImpl) setInstrumentedPlugins() { … } func (f *frameworkImpl) SetPodNominator(n framework.PodNominator) { … } // Close closes each plugin, when they implement io.Closer interface. func (f *frameworkImpl) Close() error { … } // getScoreWeights makes sure that, between MultiPoint-Score plugin weights and individual Score // plugin weights there is not an overflow of MaxTotalScore. func getScoreWeights(f *frameworkImpl, plugins []config.Plugin) error { … } type orderedSet … func newOrderedSet() *orderedSet { … } func (os *orderedSet) insert(s string) { … } func (os *orderedSet) has(s string) bool { … } func (os *orderedSet) delete(s string) { … } func (f *frameworkImpl) expandMultiPointPlugins(logger klog.Logger, profile *config.KubeSchedulerProfile) error { … } func shouldHaveEnqueueExtensions(p framework.Plugin) bool { … } func (f *frameworkImpl) fillEnqueueExtensions(p framework.Plugin) { … } type defaultEnqueueExtension … func (p *defaultEnqueueExtension) Name() string { … } func (p *defaultEnqueueExtension) EventsToRegister(_ context.Context) ([]framework.ClusterEventWithHint, error) { … } func updatePluginList(pluginList interface{ … } // PreEnqueuePlugins returns the registered preEnqueue plugins. func (f *frameworkImpl) PreEnqueuePlugins() []framework.PreEnqueuePlugin { … } // EnqueueExtensions returns the registered reenqueue plugins. func (f *frameworkImpl) EnqueueExtensions() []framework.EnqueueExtensions { … } // QueueSortFunc returns the function to sort pods in scheduling queue func (f *frameworkImpl) QueueSortFunc() framework.LessFunc { … } // RunPreFilterPlugins runs the set of configured PreFilter plugins. It returns // *Status and its code is set to non-success if any of the plugins returns // anything but Success/Skip. // When it returns Skip status, returned PreFilterResult and other fields in status are just ignored, // and coupled Filter plugin/PreFilterExtensions() will be skipped in this scheduling cycle. // If a non-success status is returned, then the scheduling cycle is aborted. func (f *frameworkImpl) RunPreFilterPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod) (_ *framework.PreFilterResult, status *framework.Status, _ sets.Set[string]) { … } func (f *frameworkImpl) runPreFilterPlugin(ctx context.Context, pl framework.PreFilterPlugin, state *framework.CycleState, pod *v1.Pod) (*framework.PreFilterResult, *framework.Status) { … } // RunPreFilterExtensionAddPod calls the AddPod interface for the set of configured // PreFilter plugins. It returns directly if any of the plugins return any // status other than Success. func (f *frameworkImpl) RunPreFilterExtensionAddPod( ctx context.Context, state *framework.CycleState, podToSchedule *v1.Pod, podInfoToAdd *framework.PodInfo, nodeInfo *framework.NodeInfo, ) (status *framework.Status) { … } func (f *frameworkImpl) runPreFilterExtensionAddPod(ctx context.Context, pl framework.PreFilterPlugin, state *framework.CycleState, podToSchedule *v1.Pod, podInfoToAdd *framework.PodInfo, nodeInfo *framework.NodeInfo) *framework.Status { … } // RunPreFilterExtensionRemovePod calls the RemovePod interface for the set of configured // PreFilter plugins. It returns directly if any of the plugins return any // status other than Success. func (f *frameworkImpl) RunPreFilterExtensionRemovePod( ctx context.Context, state *framework.CycleState, podToSchedule *v1.Pod, podInfoToRemove *framework.PodInfo, nodeInfo *framework.NodeInfo, ) (status *framework.Status) { … } func (f *frameworkImpl) runPreFilterExtensionRemovePod(ctx context.Context, pl framework.PreFilterPlugin, state *framework.CycleState, podToSchedule *v1.Pod, podInfoToRemove *framework.PodInfo, nodeInfo *framework.NodeInfo) *framework.Status { … } // RunFilterPlugins runs the set of configured Filter plugins for pod on // the given node. If any of these plugins doesn't return "Success", the // given node is not suitable for running pod. // Meanwhile, the failure message and status are set for the given node. func (f *frameworkImpl) RunFilterPlugins( ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo, ) *framework.Status { … } func (f *frameworkImpl) runFilterPlugin(ctx context.Context, pl framework.FilterPlugin, state *framework.CycleState, pod *v1.Pod, nodeInfo *framework.NodeInfo) *framework.Status { … } // RunPostFilterPlugins runs the set of configured PostFilter plugins until the first // Success, Error or UnschedulableAndUnresolvable is met; otherwise continues to execute all plugins. func (f *frameworkImpl) RunPostFilterPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, filteredNodeStatusMap framework.NodeToStatusReader) (_ *framework.PostFilterResult, status *framework.Status) { … } func (f *frameworkImpl) runPostFilterPlugin(ctx context.Context, pl framework.PostFilterPlugin, state *framework.CycleState, pod *v1.Pod, filteredNodeStatusMap framework.NodeToStatusReader) (*framework.PostFilterResult, *framework.Status) { … } // RunFilterPluginsWithNominatedPods runs the set of configured filter plugins // for nominated pod on the given node. // This function is called from two different places: Schedule and Preempt. // When it is called from Schedule, we want to test whether the pod is // schedulable on the node with all the existing pods on the node plus higher // and equal priority pods nominated to run on the node. // When it is called from Preempt, we should remove the victims of preemption // and add the nominated pods. Removal of the victims is done by // SelectVictimsOnNode(). Preempt removes victims from PreFilter state and // NodeInfo before calling this function. func (f *frameworkImpl) RunFilterPluginsWithNominatedPods(ctx context.Context, state *framework.CycleState, pod *v1.Pod, info *framework.NodeInfo) *framework.Status { … } // addNominatedPods adds pods with equal or greater priority which are nominated // to run on the node. It returns 1) whether any pod was added, 2) augmented cycleState, // 3) augmented nodeInfo. func addNominatedPods(ctx context.Context, fh framework.Handle, pod *v1.Pod, state *framework.CycleState, nodeInfo *framework.NodeInfo) (bool, *framework.CycleState, *framework.NodeInfo, error) { … } // RunPreScorePlugins runs the set of configured pre-score plugins. If any // of these plugins returns any status other than Success/Skip, the given pod is rejected. // When it returns Skip status, other fields in status are just ignored, // and coupled Score plugin will be skipped in this scheduling cycle. func (f *frameworkImpl) RunPreScorePlugins( ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodes []*framework.NodeInfo, ) (status *framework.Status) { … } func (f *frameworkImpl) runPreScorePlugin(ctx context.Context, pl framework.PreScorePlugin, state *framework.CycleState, pod *v1.Pod, nodes []*framework.NodeInfo) *framework.Status { … } // RunScorePlugins runs the set of configured scoring plugins. // It returns a list that stores scores from each plugin and total score for each Node. // It also returns *Status, which is set to non-success if any of the plugins returns // a non-success status. func (f *frameworkImpl) RunScorePlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodes []*framework.NodeInfo) (ns []framework.NodePluginScores, status *framework.Status) { … } func (f *frameworkImpl) runScorePlugin(ctx context.Context, pl framework.ScorePlugin, state *framework.CycleState, pod *v1.Pod, nodeName string) (int64, *framework.Status) { … } func (f *frameworkImpl) runScoreExtension(ctx context.Context, pl framework.ScorePlugin, state *framework.CycleState, pod *v1.Pod, nodeScoreList framework.NodeScoreList) *framework.Status { … } // RunPreBindPlugins runs the set of configured prebind plugins. It returns a // failure (bool) if any of the plugins returns an error. It also returns an // error containing the rejection message or the error occurred in the plugin. func (f *frameworkImpl) RunPreBindPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (status *framework.Status) { … } func (f *frameworkImpl) runPreBindPlugin(ctx context.Context, pl framework.PreBindPlugin, state *framework.CycleState, pod *v1.Pod, nodeName string) *framework.Status { … } // RunBindPlugins runs the set of configured bind plugins until one returns a non `Skip` status. func (f *frameworkImpl) RunBindPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (status *framework.Status) { … } func (f *frameworkImpl) runBindPlugin(ctx context.Context, bp framework.BindPlugin, state *framework.CycleState, pod *v1.Pod, nodeName string) *framework.Status { … } // RunPostBindPlugins runs the set of configured postbind plugins. func (f *frameworkImpl) RunPostBindPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) { … } func (f *frameworkImpl) runPostBindPlugin(ctx context.Context, pl framework.PostBindPlugin, state *framework.CycleState, pod *v1.Pod, nodeName string) { … } // RunReservePluginsReserve runs the Reserve method in the set of configured // reserve plugins. If any of these plugins returns an error, it does not // continue running the remaining ones and returns the error. In such a case, // the pod will not be scheduled and the caller will be expected to call // RunReservePluginsUnreserve. func (f *frameworkImpl) RunReservePluginsReserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (status *framework.Status) { … } func (f *frameworkImpl) runReservePluginReserve(ctx context.Context, pl framework.ReservePlugin, state *framework.CycleState, pod *v1.Pod, nodeName string) *framework.Status { … } // RunReservePluginsUnreserve runs the Unreserve method in the set of // configured reserve plugins. func (f *frameworkImpl) RunReservePluginsUnreserve(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) { … } func (f *frameworkImpl) runReservePluginUnreserve(ctx context.Context, pl framework.ReservePlugin, state *framework.CycleState, pod *v1.Pod, nodeName string) { … } // RunPermitPlugins runs the set of configured permit plugins. If any of these // plugins returns a status other than "Success" or "Wait", it does not continue // running the remaining plugins and returns an error. Otherwise, if any of the // plugins returns "Wait", then this function will create and add waiting pod // to a map of currently waiting pods and return status with "Wait" code. // Pod will remain waiting pod for the minimum duration returned by the permit plugins. func (f *frameworkImpl) RunPermitPlugins(ctx context.Context, state *framework.CycleState, pod *v1.Pod, nodeName string) (status *framework.Status) { … } func (f *frameworkImpl) runPermitPlugin(ctx context.Context, pl framework.PermitPlugin, state *framework.CycleState, pod *v1.Pod, nodeName string) (*framework.Status, time.Duration) { … } // WaitOnPermit will block, if the pod is a waiting pod, until the waiting pod is rejected or allowed. func (f *frameworkImpl) WaitOnPermit(ctx context.Context, pod *v1.Pod) *framework.Status { … } // SnapshotSharedLister returns the scheduler's SharedLister of the latest NodeInfo // snapshot. The snapshot is taken at the beginning of a scheduling cycle and remains // unchanged until a pod finishes "Reserve". There is no guarantee that the information // remains unchanged after "Reserve". func (f *frameworkImpl) SnapshotSharedLister() framework.SharedLister { … } // IterateOverWaitingPods acquires a read lock and iterates over the WaitingPods map. func (f *frameworkImpl) IterateOverWaitingPods(callback func(framework.WaitingPod)) { … } // GetWaitingPod returns a reference to a WaitingPod given its UID. func (f *frameworkImpl) GetWaitingPod(uid types.UID) framework.WaitingPod { … } // RejectWaitingPod rejects a WaitingPod given its UID. // The returned value indicates if the given pod is waiting or not. func (f *frameworkImpl) RejectWaitingPod(uid types.UID) bool { … } // HasFilterPlugins returns true if at least one filter plugin is defined. func (f *frameworkImpl) HasFilterPlugins() bool { … } // HasPostFilterPlugins returns true if at least one postFilter plugin is defined. func (f *frameworkImpl) HasPostFilterPlugins() bool { … } // HasScorePlugins returns true if at least one score plugin is defined. func (f *frameworkImpl) HasScorePlugins() bool { … } // ListPlugins returns a map of extension point name to plugin names configured at each extension // point. Returns nil if no plugins where configured. func (f *frameworkImpl) ListPlugins() *config.Plugins { … } // ClientSet returns a kubernetes clientset. func (f *frameworkImpl) ClientSet() clientset.Interface { … } // KubeConfig returns a kubernetes config. func (f *frameworkImpl) KubeConfig() *restclient.Config { … } // EventRecorder returns an event recorder. func (f *frameworkImpl) EventRecorder() events.EventRecorder { … } // SharedInformerFactory returns a shared informer factory. func (f *frameworkImpl) SharedInformerFactory() informers.SharedInformerFactory { … } func (f *frameworkImpl) ResourceClaimCache() *assumecache.AssumeCache { … } func (f *frameworkImpl) pluginsNeeded(plugins *config.Plugins) sets.Set[string] { … } // ProfileName returns the profile name associated to this framework. func (f *frameworkImpl) ProfileName() string { … } // PercentageOfNodesToScore returns percentageOfNodesToScore associated to a profile. func (f *frameworkImpl) PercentageOfNodesToScore() *int32 { … } // Parallelizer returns a parallelizer holding parallelism for scheduler. func (f *frameworkImpl) Parallelizer() parallelize.Parallelizer { … }
Codebase Browser
kubernetes