Skip to content

Commit

Permalink
REVIEW: adapt: wrap controller manager AddFlags with our controller list
Browse files Browse the repository at this point in the history
  • Loading branch information
Andy Goldstein authored and deads2k committed Apr 27, 2017
1 parent 360cb58 commit 672fce3
Show file tree
Hide file tree
Showing 4 changed files with 24 additions and 5 deletions.
4 changes: 2 additions & 2 deletions pkg/cmd/server/api/validation/master.go
Expand Up @@ -15,12 +15,12 @@ import (
kuval "k8s.io/apimachinery/pkg/util/validation"
"k8s.io/apimachinery/pkg/util/validation/field"
apiserveroptions "k8s.io/kubernetes/cmd/kube-apiserver/app/options"
controlleroptions "k8s.io/kubernetes/cmd/kube-controller-manager/app/options"
kvalidation "k8s.io/kubernetes/pkg/api/validation"
"k8s.io/kubernetes/pkg/serviceaccount"

"github.com/openshift/origin/pkg/cmd/server/api"
"github.com/openshift/origin/pkg/cmd/server/bootstrappolicy"
"github.com/openshift/origin/pkg/cmd/server/cm"
"github.com/openshift/origin/pkg/security/mcs"
"github.com/openshift/origin/pkg/security/uid"
"github.com/openshift/origin/pkg/util/labelselector"
Expand Down Expand Up @@ -677,7 +677,7 @@ func ValidateAPIServerExtendedArguments(config api.ExtendedArguments, fldPath *f
}

func ValidateControllerExtendedArguments(config api.ExtendedArguments, fldPath *field.Path) field.ErrorList {
return ValidateExtendedArguments(config, controlleroptions.NewCMServer().AddFlags, fldPath)
return ValidateExtendedArguments(config, cm.OriginControllerManagerAddFlags, fldPath)
}

func ValidateAdmissionPluginConfig(pluginConfig map[string]api.AdmissionPluginConfig, fieldPath *field.Path) field.ErrorList {
Expand Down
17 changes: 17 additions & 0 deletions pkg/cmd/server/cm/defaults.go
@@ -0,0 +1,17 @@
package cm

import (
"github.com/spf13/pflag"

kcmapp "k8s.io/kubernetes/cmd/kube-controller-manager/app"
kcmoptions "k8s.io/kubernetes/cmd/kube-controller-manager/app/options"
)

var (
// default to the same controllers as upstream
ControllersDisabledByDefault = kcmapp.ControllersDisabledByDefault
)

func OriginControllerManagerAddFlags(flags *pflag.FlagSet) {
kcmoptions.NewCMServer().AddFlags(flags, kcmapp.KnownControllers(), ControllersDisabledByDefault.List())
}
3 changes: 2 additions & 1 deletion pkg/cmd/server/kubernetes/master_config.go
Expand Up @@ -58,6 +58,7 @@ import (
"github.com/openshift/origin/pkg/api"
"github.com/openshift/origin/pkg/cmd/flagtypes"
configapi "github.com/openshift/origin/pkg/cmd/server/api"
"github.com/openshift/origin/pkg/cmd/server/cm"
"github.com/openshift/origin/pkg/cmd/server/crypto"
"github.com/openshift/origin/pkg/cmd/server/election"
cmdflags "github.com/openshift/origin/pkg/cmd/util/flags"
Expand Down Expand Up @@ -242,7 +243,7 @@ func BuildKubernetesMasterConfig(
// resolve extended arguments
// TODO: this should be done in config validation (along with the above) so we can provide
// proper errors
if err := cmdflags.Resolve(options.KubernetesMasterConfig.ControllerArguments, cmserver.AddFlags); len(err) > 0 {
if err := cmdflags.Resolve(options.KubernetesMasterConfig.ControllerArguments, cm.OriginControllerManagerAddFlags); len(err) > 0 {
return nil, kerrors.NewAggregate(err)
}

Expand Down
5 changes: 3 additions & 2 deletions pkg/cmd/server/start/kubernetes/controllers.go
Expand Up @@ -7,9 +7,10 @@ import (

"github.com/spf13/cobra"

"github.com/openshift/origin/pkg/cmd/server/cm"
kflag "k8s.io/apiserver/pkg/util/flag"
controllerapp "k8s.io/kubernetes/cmd/kube-controller-manager/app"
controlleroptions "k8s.io/kubernetes/cmd/kube-controller-manager/app/options"
kflag "k8s.io/kubernetes/pkg/util/flag"
"k8s.io/kubernetes/pkg/util/logs"
)

Expand Down Expand Up @@ -42,7 +43,7 @@ func NewControllersCommand(name, fullName string, out io.Writer) *cobra.Command

flags := cmd.Flags()
flags.SetNormalizeFunc(kflag.WordSepNormalizeFunc)
controllerOptions.AddFlags(flags)
cm.OriginControllerManagerAddFlags(flags)

return cmd
}

0 comments on commit 672fce3

Please sign in to comment.