@@ -33,6 +33,10 @@ import (
3333
3434 "emperror.dev/errors"
3535 "github.com/Masterminds/semver"
36+ "github.com/lestrrat-go/backoff"
37+ "github.com/spf13/cobra"
38+ "github.com/spf13/pflag"
39+
3640 "github.com/banzaicloud/pke/.gen/pipeline"
3741 "github.com/banzaicloud/pke/cmd/pke/app/config"
3842 "github.com/banzaicloud/pke/cmd/pke/app/constants"
@@ -47,9 +51,6 @@ import (
4751 "github.com/banzaicloud/pke/cmd/pke/app/util/runner"
4852 "github.com/banzaicloud/pke/cmd/pke/app/util/transport"
4953 "github.com/banzaicloud/pke/cmd/pke/app/util/validator"
50- "github.com/lestrrat-go/backoff"
51- "github.com/spf13/cobra"
52- "github.com/spf13/pflag"
5354)
5455
5556const (
@@ -92,6 +93,7 @@ type ControlPlane struct {
9293 advertiseAddress string
9394 apiServerHostPort string
9495 clusterName string
96+ nodeName string
9597 serviceCIDR string
9698 podNetworkCIDR string
9799 mtu uint
@@ -179,6 +181,8 @@ func (c *ControlPlane) RegisterFlags(flags *pflag.FlagSet) {
179181 flags .Uint (constants .FlagMTU , 0 , "maximum transmission unit. 0 means default value of the Kubernetes network provider is used" )
180182 // Kubernetes cluster name
181183 flags .String (constants .FlagClusterName , "pke" , "Kubernetes cluster name" )
184+ // Kubernetes kubadm init node name
185+ flags .String (constants .FlagNodeName , "" , "Kubernetes kubeadm node name for init" )
182186 // Kubernetes certificates
183187 flags .StringSlice (constants .FlagAPIServerCertSANs , []string {}, "sets extra Subject Alternative Names for the API Server signing cert" )
184188 flags .String (constants .FlagControllerManagerSigningCA , "" , "Kubernetes Controller Manager signing cert" )
@@ -504,7 +508,7 @@ func (c *ControlPlane) Run(out io.Writer) error {
504508 single = true
505509 }
506510 // TODO get cilium version from flag
507- version := "v1.9 .1"
511+ version := "v1.11 .1"
508512 if err := installCilium (out , kubeConfig , c .podNetworkCIDR , c .imageRepository , version , c .mtu , single ); err != nil {
509513 return err
510514 }
@@ -627,6 +631,10 @@ func (c *ControlPlane) masterBootstrapParameters(cmd *cobra.Command) (err error)
627631 if err != nil {
628632 return
629633 }
634+ c .nodeName , err = cmd .Flags ().GetString (constants .FlagNodeName )
635+ if err != nil {
636+ return
637+ }
630638 c .oidcIssuerURL , err = cmd .Flags ().GetString (constants .FlagOIDCIssuerURL )
631639 if err != nil {
632640 return
@@ -858,6 +866,11 @@ func (c *ControlPlane) installMaster(out io.Writer) error {
858866 "init" ,
859867 "--config=" + kubeadmConfig ,
860868 }
869+
870+ if c .cloudProvider == constants .CloudProviderAmazon && c .nodeName != "" {
871+ args = append (args , "--node-name=" + c .nodeName )
872+ }
873+
861874 _ , err = runner .Cmd (out , cmdKubeadm , args ... ).CombinedOutputAsync ()
862875 if err != nil {
863876 return err
0 commit comments