app

Documentation

Overview

Package app implements a Server object for running the scheduler.

Index

• func NewSchedulerCommand() *cobra.Command
• type Options
  • func NewOptions() (*Options, error)
  • func (o *Options) AddFlags(fs *pflag.FlagSet)
  • func (o *Options) ApplyDefaults(in *componentconfig.KubeSchedulerConfiguration) (*componentconfig.KubeSchedulerConfiguration, error)
  • func (o *Options) Complete() error
  • func (o *Options) Run() error
  • func (o *Options) Validate(args []string) error
• type SchedulerServer
  • func NewSchedulerServer(config *componentconfig.KubeSchedulerConfiguration, master string) (*SchedulerServer, error)
  • func (s *SchedulerServer) Run(stop <-chan struct{}) error
  • func (s *SchedulerServer) SchedulerConfig() (*scheduler.Config, error)

Functions

func NewSchedulerCommand

func NewSchedulerCommand() *cobra.Command

NewSchedulerCommand creates a *cobra.Command object with default parameters

Types

type Options

type Options struct {
	// ConfigFile is the location of the scheduler server's configuration file.
	ConfigFile string
	// contains filtered or unexported fields
}

SchedulerServer has all the context and params needed to run a Scheduler

func NewOptions

func NewOptions() (*Options, error)

func (*Options) AddFlags

func (o *Options) AddFlags(fs *pflag.FlagSet)

AddFlags adds flags for a specific SchedulerServer to the specified FlagSet

func (*Options) ApplyDefaults

func (o *Options) ApplyDefaults(in *componentconfig.KubeSchedulerConfiguration) (*componentconfig.KubeSchedulerConfiguration, error)

func (*Options) Complete

func (o *Options) Complete() error

func (*Options) Run

func (o *Options) Run() error

func (*Options) Validate

func (o *Options) Validate(args []string) error

Validate validates all the required options.

type SchedulerServer

type SchedulerServer struct {
	SchedulerName                  string
	Client                         clientset.Interface
	InformerFactory                informers.SharedInformerFactory
	PodInformer                    coreinformers.PodInformer
	AlgorithmSource                componentconfig.SchedulerAlgorithmSource
	HardPodAffinitySymmetricWeight int32
	EventClient                    v1core.EventsGetter
	Recorder                       record.EventRecorder
	Broadcaster                    record.EventBroadcaster
	// LeaderElection is optional.
	LeaderElection *leaderelection.LeaderElectionConfig
	// HealthzServer is optional.
	HealthzServer *http.Server
	// MetricsServer is optional.
	MetricsServer *http.Server
}

SchedulerServer represents all the parameters required to start the Kubernetes scheduler server.

func NewSchedulerServer

func NewSchedulerServer(config *componentconfig.KubeSchedulerConfiguration, master string) (*SchedulerServer, error)

NewSchedulerServer creates a runnable SchedulerServer from configuration.

func (*SchedulerServer) Run

func (s *SchedulerServer) Run(stop <-chan struct{}) error

Run runs the SchedulerServer. This should never exit.

func (*SchedulerServer) SchedulerConfig

func (s *SchedulerServer) SchedulerConfig() (*scheduler.Config, error)

SchedulerConfig creates the scheduler configuration. This is exposed for use by tests.