mirror of https://github.com/k3s-io/k3s
commit
d3a2566371
|
@ -156,6 +156,9 @@ func runCommand(cmd *cobra.Command, args []string, opts *options.Options) error
|
||||||
|
|
||||||
// Run executes the scheduler based on the given configuration. It only return on error or when stopCh is closed.
|
// Run executes the scheduler based on the given configuration. It only return on error or when stopCh is closed.
|
||||||
func Run(cc schedulerserverconfig.CompletedConfig, stopCh <-chan struct{}) error {
|
func Run(cc schedulerserverconfig.CompletedConfig, stopCh <-chan struct{}) error {
|
||||||
|
// To help debugging, immediately log version
|
||||||
|
klog.V(1).Infof("Starting Kubernetes Scheduler version %+v", version.Get())
|
||||||
|
|
||||||
// Create the scheduler.
|
// Create the scheduler.
|
||||||
sched, err := scheduler.New(cc.Client,
|
sched, err := scheduler.New(cc.Client,
|
||||||
cc.InformerFactory.Core().V1().Nodes(),
|
cc.InformerFactory.Core().V1().Nodes(),
|
||||||
|
|
Loading…
Reference in New Issue