Skip to content

Commit 70b5401

Browse files
committed
improve variable naming, get rid of misleading TODO
On-behalf-of: @SAP [email protected]
1 parent 3b1cb3d commit 70b5401

File tree

2 files changed

+14
-23
lines changed

2 files changed

+14
-23
lines changed

cmd/kcp/kcp.go

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -78,8 +78,8 @@ func main() {
7878
}
7979
}
8080

81-
serverOptions := options.NewOptions(rootDir)
82-
serverOptions.Server.GenericControlPlane.Logs.Verbosity = logsapiv1.VerbosityLevel(2)
81+
kcpOptions := options.NewOptions(rootDir)
82+
kcpOptions.Server.GenericControlPlane.Logs.Verbosity = logsapiv1.VerbosityLevel(2)
8383

8484
startCmd := &cobra.Command{
8585
Use: "start",
@@ -101,30 +101,30 @@ func main() {
101101
},
102102
RunE: func(cmd *cobra.Command, args []string) error {
103103
// run as early as possible to avoid races later when some components (e.g. grpc) start early using klog
104-
if err := logsapiv1.ValidateAndApply(serverOptions.Server.GenericControlPlane.Logs, kcpfeatures.DefaultFeatureGate); err != nil {
104+
if err := logsapiv1.ValidateAndApply(kcpOptions.Server.GenericControlPlane.Logs, kcpfeatures.DefaultFeatureGate); err != nil {
105105
return err
106106
}
107107

108-
completed, err := serverOptions.Complete()
108+
completedKcpOptions, err := kcpOptions.Complete()
109109
if err != nil {
110110
return err
111111
}
112112

113-
if errs := completed.Validate(); len(errs) > 0 {
113+
if errs := completedKcpOptions.Validate(); len(errs) > 0 {
114114
return errors.NewAggregate(errs)
115115
}
116116

117117
logger := klog.FromContext(cmd.Context())
118-
logger.Info("running with selected batteries", "batteries", strings.Join(completed.Server.Extra.BatteriesIncluded, ","))
118+
logger.Info("running with selected batteries", "batteries", strings.Join(completedKcpOptions.Server.Extra.BatteriesIncluded, ","))
119119

120120
ctx := genericapiserver.SetupSignalContext()
121121

122-
serverConfig, err := server.NewConfig(ctx, completed.Server)
122+
serverConfig, err := server.NewConfig(ctx, completedKcpOptions.Server)
123123
if err != nil {
124124
return err
125125
}
126126

127-
completedConfig, err := config.Complete()
127+
completedConfig, err := serverConfig.Complete()
128128
if err != nil {
129129
return err
130130
}
@@ -146,7 +146,7 @@ func main() {
146146

147147
// add start named flag sets to start flags
148148
fss := cliflag.NamedFlagSets{}
149-
serverOptions.AddFlags(&fss)
149+
kcpOptions.AddFlags(&fss)
150150
globalflag.AddGlobalFlags(fss.FlagSet("global"), cmd.Name(), logs.SkipLoggingConfigurationFlags())
151151
startFlags := startCmd.Flags()
152152
for _, f := range fss.FlagSets {

pkg/server/options/options.go

Lines changed: 5 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,6 @@ import (
2929
genericapiserveroptions "k8s.io/apiserver/pkg/server/options"
3030
cliflag "k8s.io/component-base/cli/flag"
3131
controlplaneapiserver "k8s.io/kubernetes/pkg/controlplane/apiserver/options"
32-
authzmodes "k8s.io/kubernetes/pkg/kubeapiserver/authorizer/modes"
3332

3433
kcpadmission "github.com/kcp-dev/kcp/pkg/admission"
3534
etcdoptions "github.com/kcp-dev/kcp/pkg/embeddedetcd/options"
@@ -114,15 +113,6 @@ func NewOptions(rootDir string) *Options {
114113

115114
// override all the stuff
116115
o.GenericControlPlane.SecureServing.ServerCert.CertDirectory = rootDir
117-
o.GenericControlPlane.Authentication = kubeoptions.NewBuiltInAuthenticationOptions().
118-
WithAnonymous().
119-
WithBootstrapToken().
120-
WithClientCert().
121-
WithOIDC().
122-
WithRequestHeader().
123-
WithServiceAccounts().
124-
WithTokenFile().
125-
WithWebHook()
126116
o.GenericControlPlane.Authentication.ServiceAccounts.Issuers = []string{"https://kcp.default.svc"}
127117
o.GenericControlPlane.Etcd.StorageConfig.Transport.ServerList = []string{"embedded"}
128118
o.GenericControlPlane.Authorization = nil // we have our own
@@ -315,7 +305,9 @@ func (o *Options) Complete(rootDir string) (*CompletedOptions, error) {
315305
}
316306
if o.GenericControlPlane.ServiceAccountSigningKeyFile == "" {
317307
o.GenericControlPlane.ServiceAccountSigningKeyFile = o.Controllers.SAController.ServiceAccountKeyFile
318-
completedGenericServerRunOptions, err := o.GenericControlPlane.Complete(nil, nil)
308+
}
309+
310+
completedGenericOptions, err := o.GenericControlPlane.Complete(nil, nil)
319311
if err != nil {
320312
return nil, err
321313
}
@@ -354,16 +346,15 @@ func (o *Options) Complete(rootDir string) (*CompletedOptions, error) {
354346
// we already do that for cluster names (stored in the obj)
355347
// - we need to modify wildcardClusterNameRegex and crdWildcardPartialMetadataClusterNameRegex
356348
o.Cache.Server.Etcd.EnableWatchCache = false
357-
o.Cache.Server.SecureServing = completedGenericServerRunOptions.SecureServing
349+
o.Cache.Server.SecureServing = completedGenericOptions.SecureServing
358350
cacheCompletedOptions, err := o.Cache.Complete()
359351
if err != nil {
360352
return nil, err
361353
}
362354

363355
return &CompletedOptions{
364356
completedOptions: &completedOptions{
365-
// TODO: GenericControlPlane here should be completed. But the k/k repo does not expose the CompleteOptions type, but should.
366-
GenericControlPlane: completedGenericServerRunOptions,
357+
GenericControlPlane: completedGenericOptions,
367358
EmbeddedEtcd: completedEmbeddedEtcd,
368359
Controllers: o.Controllers,
369360
Authorization: o.Authorization,

0 commit comments

Comments
 (0)