feature(main): fix labring#960 for controller and schedule bind 0.0.0.0

pkg/runtime/default_kubeadm_config.go

@@ -15,8 +15,7 @@
 package runtime
 
 const (
-	DefaultKubeadmConfig = `
-apiVersion: kubeadm.k8s.io/v1beta2
+	DefaultKubeadmConfig = `apiVersion: kubeadm.k8s.io/v1beta2
 kind: InitConfiguration
 localAPIEndpoint:
   # advertiseAddress: 192.168.2.110
@@ -66,6 +65,7 @@ apiServer:
       pathType: File
 controllerManager:
   extraArgs:
+    bind-address: 0.0.0.0
     feature-gates: TTLAfterFinished=true,EphemeralContainers=true
     experimental-cluster-signing-duration: 876000h
   extraVolumes:
@@ -76,6 +76,7 @@ controllerManager:
       pathType: File
 scheduler:
   extraArgs:
+    bind-address: 0.0.0.0
     feature-gates: TTLAfterFinished=true,EphemeralContainers=true
   extraVolumes:
     - hostPath: /etc/localtime

pkg/runtime/init.go

@@ -28,7 +28,7 @@ func (k *KubeadmRuntime) ConfigInitKubeadmToMaster0() error {
 	logger.Info("start to copy kubeadm config to master0")
 	data, err := k.generateInitConfigs()
 	if err != nil {
-		return fmt.Errorf("generator config init kubeadm Config error: %s", err.Error())
+		return fmt.Errorf("generator config init kubeadm config error: %s", err.Error())
 	}
 	initConfigPath := path.Join(k.getContentData().TmpPath(), contants.DefaultInitKubeadmFileName)
 	outConfigPath := path.Join(k.getContentData().EtcPath(), contants.DefaultInitKubeadmFileName)

pkg/runtime/kubeadm.go

@@ -115,11 +115,11 @@ func (k *KubeadmRuntime) getCGroupDriver(node string) (string, error) {
 func (k *KubeadmRuntime) MergeKubeadmConfig() error {
 	if k.Config.ClusterFileKubeConfig != nil {
 		if err := k.LoadFromClusterfile(k.Config.ClusterFileKubeConfig); err != nil {
-			return fmt.Errorf("failed to load kubeadm Config from clusterfile: %v", err)
+			return fmt.Errorf("failed to load kubeadm config from clusterfile: %v", err)
 		}
 	}
 	if err := k.Merge(k.getDefaultKubeadmConfig()); err != nil {
-		return fmt.Errorf("failed to merge kubeadm Config: %v", err)
+		return fmt.Errorf("failed to merge kubeadm config: %v", err)
 	}
 	k.setKubeadmAPIVersion()
 	return nil

pkg/runtime/kubeadm_config.go

@@ -88,12 +88,12 @@ func (k *KubeadmConfig) Merge(kubeadmYamlPath string) error {
 	}
 	defaultKubeadmConfig, err = LoadKubeadmConfigs(kubeadmYamlPath, DecodeCRDFromFile)
 	if err != nil {
-		return fmt.Errorf("failed to found kubeadm Config from %s: %v", kubeadmYamlPath, err)
+		return fmt.Errorf("failed to found kubeadm config from %s: %v", kubeadmYamlPath, err)
 	}
 	k.APIServer.CertSANs = append(k.APIServer.CertSANs, defaultKubeadmConfig.APIServer.CertSANs...)
 	err = mergo.Merge(k, defaultKubeadmConfig)
 	if err != nil {
-		return fmt.Errorf("failed to merge kubeadm Config: %v", err)
+		return fmt.Errorf("failed to merge kubeadm config: %v", err)
 	}
 	//using the DefaultKubeadmConfig configuration merge
 	return k.Merge("")

pkg/runtime/master.go

@@ -85,7 +85,7 @@ func (k *KubeadmRuntime) ConfigJoinMasterKubeadmToMaster(master string) error {
 	}
 	err = k.sshCopy(master, joinConfigPath, outConfigPath)
 	if err != nil {
-		return fmt.Errorf("copy Config join master kubeadm Config error: %s", err.Error())
+		return fmt.Errorf("copy config join master kubeadm config error: %s", err.Error())
 	}
 	return nil
 }