const durationToExpireAssumedPod … var ErrNoNodesAvailable … type Scheduler … func (sched *Scheduler) applyDefaultHandlers() { … } type schedulerOptions … type Option … type ScheduleResult … // 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(apiVersion string) Option { … } // WithKubeConfig sets the kube config for Scheduler. func WithKubeConfig(cfg *restclient.Config) Option { … } // WithProfiles sets profiles for Scheduler. By default, there is one profile // with the name "default-scheduler". func WithProfiles(p ...schedulerapi.KubeSchedulerProfile) Option { … } // WithParallelism sets the parallelism for all scheduler algorithms. Default is 16. func WithParallelism(threads int32) Option { … } // WithPercentageOfNodesToScore sets percentageOfNodesToScore for Scheduler. // The default value of 0 will use an adaptive percentage: 50 - (num of nodes)/125. func WithPercentageOfNodesToScore(percentageOfNodesToScore *int32) Option { … } // WithFrameworkOutOfTreeRegistry sets the registry for out-of-tree plugins. Those plugins // will be appended to the default registry. func WithFrameworkOutOfTreeRegistry(registry frameworkruntime.Registry) Option { … } // WithPodInitialBackoffSeconds sets podInitialBackoffSeconds for Scheduler, the default value is 1 func WithPodInitialBackoffSeconds(podInitialBackoffSeconds int64) Option { … } // WithPodMaxBackoffSeconds sets podMaxBackoffSeconds for Scheduler, the default value is 10 func WithPodMaxBackoffSeconds(podMaxBackoffSeconds int64) Option { … } // WithPodMaxInUnschedulablePodsDuration sets podMaxInUnschedulablePodsDuration for PriorityQueue. func WithPodMaxInUnschedulablePodsDuration(duration time.Duration) Option { … } // WithExtenders sets extenders for the Scheduler func WithExtenders(e ...schedulerapi.Extender) Option { … } type FrameworkCapturer … // WithBuildFrameworkCapturer sets a notify function for getting buildFramework details. func WithBuildFrameworkCapturer(fc FrameworkCapturer) Option { … } var defaultSchedulerOptions … // New returns a Scheduler func New(ctx context.Context, client clientset.Interface, informerFactory informers.SharedInformerFactory, dynInformerFactory dynamicinformer.DynamicSharedInformerFactory, recorderFactory profile.RecorderFactory, opts ...Option) (*Scheduler, error) { … } var defaultQueueingHintFn … func buildQueueingHintMap(ctx context.Context, es []framework.EnqueueExtensions) (internalqueue.QueueingHintMap, error) { … } // Run begins watching and scheduling. It starts scheduling and blocked until the context is done. func (sched *Scheduler) Run(ctx context.Context) { … } // NewInformerFactory creates a SharedInformerFactory and initializes a scheduler specific // in-place podInformer. func NewInformerFactory(cs clientset.Interface, resyncPeriod time.Duration) informers.SharedInformerFactory { … } func buildExtenders(logger klog.Logger, extenders []schedulerapi.Extender, profiles []schedulerapi.KubeSchedulerProfile) ([]framework.Extender, error) { … } type FailureHandlerFn … func unionedGVKs(queueingHintsPerProfile internalqueue.QueueingHintMapPerProfile) map[framework.EventResource]framework.ActionType { … } // newPodInformer creates a shared index informer that returns only non-terminal pods. // The PodInformer allows indexers to be added, but note that only non-conflict indexers are allowed. func newPodInformer(cs clientset.Interface, resyncPeriod time.Duration) cache.SharedIndexInformer { … }
Codebase Browser
kubernetes