mirror of
https://github.com/k3s-io/kubernetes.git
synced 2025-07-29 06:27:05 +00:00
Merge pull request #44287 from shashidharatd/federation-cm
Automatic merge from submit-queue (batch tested with PRs 43273, 44287, 44281) [Federation] Remove deprecated federation-apiserver-kubeconfig secret federation-apiserver-kubeconfig was deprecated and was supposed to be removed in 1.6. Removing all references to it as we no longer use it. **Release note**: ``` [Federation] Deprecated `federation-apiserver-kubeconfig` is not supported anymore. Should use `--kubeconfig` flag to specify Federation API server kubeconfig. ``` cc @kubernetes/sig-federation-pr-reviews
This commit is contained in:
commit
478f469ff6
@ -31,7 +31,6 @@ go_library(
|
|||||||
"//federation/pkg/federation-controller/replicaset:go_default_library",
|
"//federation/pkg/federation-controller/replicaset:go_default_library",
|
||||||
"//federation/pkg/federation-controller/secret:go_default_library",
|
"//federation/pkg/federation-controller/secret:go_default_library",
|
||||||
"//federation/pkg/federation-controller/service:go_default_library",
|
"//federation/pkg/federation-controller/service:go_default_library",
|
||||||
"//federation/pkg/federation-controller/util:go_default_library",
|
|
||||||
"//pkg/util/configz:go_default_library",
|
"//pkg/util/configz:go_default_library",
|
||||||
"//pkg/version:go_default_library",
|
"//pkg/version:go_default_library",
|
||||||
"//vendor:github.com/golang/glog",
|
"//vendor:github.com/golang/glog",
|
||||||
|
@ -20,7 +20,6 @@ limitations under the License.
|
|||||||
package app
|
package app
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"fmt"
|
|
||||||
"net"
|
"net"
|
||||||
"net/http"
|
"net/http"
|
||||||
"net/http/pprof"
|
"net/http/pprof"
|
||||||
@ -46,7 +45,6 @@ import (
|
|||||||
replicasetcontroller "k8s.io/kubernetes/federation/pkg/federation-controller/replicaset"
|
replicasetcontroller "k8s.io/kubernetes/federation/pkg/federation-controller/replicaset"
|
||||||
secretcontroller "k8s.io/kubernetes/federation/pkg/federation-controller/secret"
|
secretcontroller "k8s.io/kubernetes/federation/pkg/federation-controller/secret"
|
||||||
servicecontroller "k8s.io/kubernetes/federation/pkg/federation-controller/service"
|
servicecontroller "k8s.io/kubernetes/federation/pkg/federation-controller/service"
|
||||||
"k8s.io/kubernetes/federation/pkg/federation-controller/util"
|
|
||||||
"k8s.io/kubernetes/pkg/util/configz"
|
"k8s.io/kubernetes/pkg/util/configz"
|
||||||
"k8s.io/kubernetes/pkg/version"
|
"k8s.io/kubernetes/pkg/version"
|
||||||
|
|
||||||
@ -58,16 +56,6 @@ import (
|
|||||||
"k8s.io/client-go/discovery"
|
"k8s.io/client-go/discovery"
|
||||||
)
|
)
|
||||||
|
|
||||||
const (
|
|
||||||
// "federation-apiserver-kubeconfig" was the old name we used to
|
|
||||||
// store Federation API server kubeconfig secret. We are
|
|
||||||
// deprecating it in favor of `--kubeconfig` flag but giving people
|
|
||||||
// time to migrate.
|
|
||||||
// TODO(madhusudancs): this name is deprecated in 1.5 and should be
|
|
||||||
// removed in 1.6. Remove it in 1.6.
|
|
||||||
DeprecatedKubeconfigSecretName = "federation-apiserver-kubeconfig"
|
|
||||||
)
|
|
||||||
|
|
||||||
// NewControllerManagerCommand creates a *cobra.Command object with default parameters
|
// NewControllerManagerCommand creates a *cobra.Command object with default parameters
|
||||||
func NewControllerManagerCommand() *cobra.Command {
|
func NewControllerManagerCommand() *cobra.Command {
|
||||||
s := options.NewCMServer()
|
s := options.NewCMServer()
|
||||||
@ -97,28 +85,10 @@ func Run(s *options.CMServer) error {
|
|||||||
glog.Errorf("unable to register configz: %s", err)
|
glog.Errorf("unable to register configz: %s", err)
|
||||||
}
|
}
|
||||||
|
|
||||||
// If s.Kubeconfig flag is empty, try with the deprecated name in 1.5.
|
restClientCfg, err := clientcmd.BuildConfigFromFlags(s.Master, s.Kubeconfig)
|
||||||
// TODO(madhusudancs): Remove this in 1.6.
|
if err != nil || restClientCfg == nil {
|
||||||
var restClientCfg *restclient.Config
|
glog.V(2).Infof("Couldn't build the rest client config from flags: %v", err)
|
||||||
var err error
|
return err
|
||||||
if len(s.Kubeconfig) <= 0 {
|
|
||||||
restClientCfg, err = restClientConfigFromSecret(s.Master)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
// Create the config to talk to federation-apiserver.
|
|
||||||
restClientCfg, err = clientcmd.BuildConfigFromFlags(s.Master, s.Kubeconfig)
|
|
||||||
if err != nil || restClientCfg == nil {
|
|
||||||
// Retry with the deprecated name in 1.5.
|
|
||||||
// TODO(madhusudancs): Remove this in 1.6.
|
|
||||||
glog.V(2).Infof("Couldn't build the rest client config from flags: %v", err)
|
|
||||||
glog.V(2).Infof("Trying with deprecated secret: %s", DeprecatedKubeconfigSecretName)
|
|
||||||
restClientCfg, err = restClientConfigFromSecret(s.Master)
|
|
||||||
if err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Override restClientCfg qps/burst settings from flags
|
// Override restClientCfg qps/burst settings from flags
|
||||||
@ -229,17 +199,6 @@ func StartControllers(s *options.CMServer, restClientCfg *restclient.Config) err
|
|||||||
select {}
|
select {}
|
||||||
}
|
}
|
||||||
|
|
||||||
// TODO(madhusudancs): Remove this in 1.6. This is only temporary to give an
|
|
||||||
// upgrade path in 1.4/1.5.
|
|
||||||
func restClientConfigFromSecret(master string) (*restclient.Config, error) {
|
|
||||||
kubeconfigGetter := util.KubeconfigGetterForSecret(DeprecatedKubeconfigSecretName)
|
|
||||||
restClientCfg, err := clientcmd.BuildConfigFromKubeconfigGetter(master, kubeconfigGetter)
|
|
||||||
if err != nil {
|
|
||||||
return nil, fmt.Errorf("failed to find the Federation API server kubeconfig, tried the --kubeconfig flag and the deprecated secret %s: %v", DeprecatedKubeconfigSecretName, err)
|
|
||||||
}
|
|
||||||
return restClientCfg, nil
|
|
||||||
}
|
|
||||||
|
|
||||||
func controllerEnabled(controllers utilflag.ConfigurationMap, serverResources []*metav1.APIResourceList, controller string, requiredResources []schema.GroupVersionResource, defaultValue bool) bool {
|
func controllerEnabled(controllers utilflag.ConfigurationMap, serverResources []*metav1.APIResourceList, controller string, requiredResources []schema.GroupVersionResource, defaultValue bool) bool {
|
||||||
controllerConfig, ok := controllers[controller]
|
controllerConfig, ok := controllers[controller]
|
||||||
if ok {
|
if ok {
|
||||||
|
Loading…
Reference in New Issue
Block a user