From d6dc0e561f5c6de6e73b1a6a5eedeb5ee471b2ec Mon Sep 17 00:00:00 2001 From: "Dr. Stefan Schimanski" Date: Tue, 25 Oct 2016 08:08:01 +0200 Subject: [PATCH] Apiserver cleanups - remove unused genericapiserver Config.MasterServiceNamespace - move init code into ApplyOptions - initialize genericapiserver Config.MaxRequestsInFlight - move ServiceReadWritePort to master --- cmd/kube-apiserver/app/server.go | 3 --- federation/cmd/federation-apiserver/app/server.go | 3 --- pkg/genericapiserver/config.go | 12 ++++++------ pkg/genericapiserver/options/server_run_options.go | 2 +- 4 files changed, 7 insertions(+), 13 deletions(-) diff --git a/cmd/kube-apiserver/app/server.go b/cmd/kube-apiserver/app/server.go index 33d1fdc6f9..e0017c835c 100644 --- a/cmd/kube-apiserver/app/server.go +++ b/cmd/kube-apiserver/app/server.go @@ -299,12 +299,9 @@ func Run(s *options.APIServer) error { genericConfig.Version = &kubeVersion genericConfig.LoopbackClientConfig = selfClientConfig genericConfig.Authenticator = apiAuthenticator - genericConfig.SupportsBasicAuth = len(s.BasicAuthFile) > 0 genericConfig.Authorizer = apiAuthorizer - genericConfig.AuthorizerRBACSuperUser = s.AuthorizationRBACSuperUser genericConfig.AdmissionControl = admissionController genericConfig.APIResourceConfigSource = storageFactory.APIResourceConfigSource - genericConfig.MasterServiceNamespace = s.MasterServiceNamespace genericConfig.OpenAPIConfig.Info.Title = "Kubernetes" genericConfig.OpenAPIConfig.Definitions = generatedopenapi.OpenAPIDefinitions genericConfig.EnableOpenAPISupport = true diff --git a/federation/cmd/federation-apiserver/app/server.go b/federation/cmd/federation-apiserver/app/server.go index 1b8806b9dd..6816516269 100644 --- a/federation/cmd/federation-apiserver/app/server.go +++ b/federation/cmd/federation-apiserver/app/server.go @@ -189,12 +189,9 @@ func Run(s *options.ServerRunOptions) error { genericConfig.Version = &kubeVersion genericConfig.LoopbackClientConfig = selfClientConfig genericConfig.Authenticator = apiAuthenticator - genericConfig.SupportsBasicAuth = len(s.BasicAuthFile) > 0 genericConfig.Authorizer = apiAuthorizer - genericConfig.AuthorizerRBACSuperUser = s.AuthorizationRBACSuperUser genericConfig.AdmissionControl = admissionController genericConfig.APIResourceConfigSource = storageFactory.APIResourceConfigSource - genericConfig.MasterServiceNamespace = s.MasterServiceNamespace genericConfig.OpenAPIConfig.Definitions = openapi.OpenAPIDefinitions genericConfig.EnableOpenAPISupport = true genericConfig.OpenAPIConfig.SecurityDefinitions = securityDefinitions diff --git a/pkg/genericapiserver/config.go b/pkg/genericapiserver/config.go index 13eb00fad8..0a3e7c20a5 100644 --- a/pkg/genericapiserver/config.go +++ b/pkg/genericapiserver/config.go @@ -84,14 +84,12 @@ type Config struct { EnableGarbageCollection bool Version *version.Info - APIGroupPrefix string CorsAllowedOriginList []string Authenticator authenticator.Request // TODO(roberthbailey): Remove once the server no longer supports http basic auth. - SupportsBasicAuth bool - Authorizer authorizer.Authorizer - AdmissionControl admission.Interface - MasterServiceNamespace string + SupportsBasicAuth bool + Authorizer authorizer.Authorizer + AdmissionControl admission.Interface // TODO(ericchiang): Determine if policy escalation checks should be an admission controller. AuthorizerRBACSuperUser string @@ -275,6 +273,7 @@ func (c *Config) ApplyOptions(options *options.ServerRunOptions) *Config { c.InsecureServingInfo = insecureServingInfo } + c.AuthorizerRBACSuperUser = options.AuthorizationRBACSuperUser c.CorsAllowedOriginList = options.CorsAllowedOriginList c.EnableGarbageCollection = options.EnableGarbageCollection c.EnableProfiling = options.EnableProfiling @@ -282,11 +281,12 @@ func (c *Config) ApplyOptions(options *options.ServerRunOptions) *Config { c.ExternalHost = options.ExternalHost c.KubernetesServiceNodePort = options.KubernetesServiceNodePort c.MasterCount = options.MasterCount + c.MaxRequestsInFlight = options.MaxRequestsInFlight c.MinRequestTimeout = options.MinRequestTimeout c.PublicAddress = options.AdvertiseAddress c.ServiceClusterIPRange = &options.ServiceClusterIPRange c.ServiceNodePortRange = options.ServiceNodePortRange - c.MaxRequestsInFlight = options.MaxRequestsInFlight + c.SupportsBasicAuth = len(options.BasicAuthFile) > 0 return c } diff --git a/pkg/genericapiserver/options/server_run_options.go b/pkg/genericapiserver/options/server_run_options.go index 69de738403..79c4d25bb6 100644 --- a/pkg/genericapiserver/options/server_run_options.go +++ b/pkg/genericapiserver/options/server_run_options.go @@ -393,7 +393,7 @@ func (s *ServerRunOptions) AddUniversalFlags(fs *pflag.FlagSet) { "The number of apiservers running in the cluster.") fs.StringVar(&s.MasterServiceNamespace, "master-service-namespace", s.MasterServiceNamespace, ""+ - "The namespace from which the kubernetes master services should be injected into pods.") + "DEPRECATED: the namespace from which the kubernetes master services should be injected into pods.") fs.IntVar(&s.MaxRequestsInFlight, "max-requests-inflight", s.MaxRequestsInFlight, ""+ "The maximum number of requests in flight at a given time. When the server exceeds this, "+