mirror of https://github.com/k3s-io/k3s
commit
823530d4db
|
@ -205,7 +205,7 @@ func (o *Options) Config() (*schedulerappconfig.Config, error) {
|
|||
return nil, err
|
||||
}
|
||||
|
||||
// prepare kube clients.
|
||||
// Prepare kube clients.
|
||||
client, leaderElectionClient, eventClient, err := createClients(c.ComponentConfig.ClientConnection, o.Master, c.ComponentConfig.LeaderElection.RenewDeadline.Duration)
|
||||
if err != nil {
|
||||
return nil, err
|
||||
|
|
|
@ -130,7 +130,7 @@ type configFactory struct {
|
|||
// Handles volume binding decisions
|
||||
volumeBinder *volumebinder.VolumeBinder
|
||||
|
||||
// always check all predicates even if the middle of one predicate fails.
|
||||
// Always check all predicates even if the middle of one predicate fails.
|
||||
alwaysCheckAllPredicates bool
|
||||
|
||||
// Disable pod preemption or not.
|
||||
|
@ -161,7 +161,7 @@ type ConfigFactoryArgs struct {
|
|||
BindTimeoutSeconds int64
|
||||
}
|
||||
|
||||
// NewConfigFactory initializes the default implementation of a Configurator To encourage eventual privatization of the struct type, we only
|
||||
// NewConfigFactory initializes the default implementation of a Configurator. To encourage eventual privatization of the struct type, we only
|
||||
// return the interface.
|
||||
func NewConfigFactory(args *ConfigFactoryArgs) scheduler.Configurator {
|
||||
stopEverything := make(chan struct{})
|
||||
|
|
|
@ -186,7 +186,7 @@ func (sched *Scheduler) Run() {
|
|||
go wait.Until(sched.scheduleOne, 0, sched.config.StopEverything)
|
||||
}
|
||||
|
||||
// Config return scheduler's config pointer. It is exposed for testing purposes.
|
||||
// Config returns scheduler's config pointer. It is exposed for testing purposes.
|
||||
func (sched *Scheduler) Config() *Config {
|
||||
return sched.config
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue