-
Notifications
You must be signed in to change notification settings - Fork 1.4k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
- Loading branch information
1 parent
e5880a4
commit 9747545
Showing
6 changed files
with
292 additions
and
104 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,144 @@ | ||
| package upgrade | ||
|
|
||
| import ( | ||
| "fmt" | ||
| "time" | ||
|
|
||
| "github.com/kris-nova/logger" | ||
| "github.com/pkg/errors" | ||
| "github.com/spf13/cobra" | ||
| "github.com/spf13/pflag" | ||
|
|
||
| api "github.com/weaveworks/eksctl/pkg/apis/eksctl.io/v1alpha5" | ||
| "github.com/weaveworks/eksctl/pkg/ctl/cmdutils" | ||
| "github.com/weaveworks/eksctl/pkg/printers" | ||
| ) | ||
|
|
||
| func upgradeCluster(cmd *cmdutils.Cmd) { | ||
| upgradeClusterWithRunFunc(cmd, DoUpgradeCluster) | ||
| } | ||
|
|
||
| func upgradeClusterWithRunFunc(cmd *cmdutils.Cmd, runFunc func(cmd *cmdutils.Cmd) error) { | ||
| cfg := api.NewClusterConfig() | ||
| cmd.ClusterConfig = cfg | ||
|
|
||
| cmd.SetDescription("cluster", "Upgrade control plane to the next version", | ||
| "Upgrade control plane to the next Kubernetes version if available. Will also perform any updates needed in the cluster stack if resources are missing.") | ||
|
|
||
| cmdutils.AddCommonFlagsForAWS(cmd.FlagSetGroup, cmd.ProviderConfig, false) | ||
|
|
||
| cmd.FlagSetGroup.InFlagSet("General", func(fs *pflag.FlagSet) { | ||
| fs.StringVarP(&cfg.Metadata.Name, "name", "n", "", "EKS cluster name") | ||
| cmdutils.AddRegionFlag(fs, cmd.ProviderConfig) | ||
| cmdutils.AddConfigFileFlag(fs, &cmd.ClusterConfigFile) | ||
|
|
||
| // cmdutils.AddVersionFlag(fs, cfg.Metadata, `"next" and "latest" can be used to automatically increment version by one, or force latest`) | ||
|
|
||
| cmdutils.AddApproveFlag(fs, cmd) | ||
|
|
||
| // updating from 1.15 to 1.16 has been observed to take longer than the default value of 25 minutes | ||
| cmdutils.AddTimeoutFlagWithValue(fs, &cmd.ProviderConfig.WaitTimeout, 35*time.Minute) | ||
| }) | ||
|
|
||
| cmd.CobraCommand.RunE = func(_ *cobra.Command, args []string) error { | ||
| cmd.NameArg = cmdutils.GetNameArg(args) | ||
|
|
||
| if err := cmdutils.NewMetadataLoader(cmd).Load(); err != nil { | ||
| return err | ||
| } | ||
| return runFunc(cmd) | ||
| } | ||
| } | ||
|
|
||
| // DoUpgradeCluster made public so that it can be shared with update/cluster.go until this is deprecated | ||
| // TODO Once `eksctl update cluster` is officially deprecated this can be made package private again | ||
| func DoUpgradeCluster(cmd *cmdutils.Cmd) error { | ||
| cfg := cmd.ClusterConfig | ||
| meta := cmd.ClusterConfig.Metadata | ||
|
|
||
| printer := printers.NewJSONPrinter() | ||
|
|
||
| ctl, err := cmd.NewCtl() | ||
| if err != nil { | ||
| return err | ||
| } | ||
| cmdutils.LogRegionAndVersionInfo(meta) | ||
|
|
||
| if err := ctl.CheckAuth(); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| if ok, err := ctl.CanUpdate(cfg); !ok { | ||
| return err | ||
| } | ||
|
|
||
| if cmd.ClusterConfigFile != "" { | ||
| logger.Warning("NOTE: config file is used for finding cluster name and region") | ||
| logger.Warning("NOTE: cluster VPC (subnets, routing & NAT Gateway) configuration changes are not yet implemented") | ||
| } | ||
|
|
||
| currentVersion := ctl.ControlPlaneVersion() | ||
| // determine next version based on what's currently deployed | ||
| switch currentVersion { | ||
| case "": | ||
| return errors.New("unable to get control plane version") | ||
| case api.Version1_12: | ||
| cfg.Metadata.Version = api.Version1_13 | ||
| case api.Version1_13: | ||
| cfg.Metadata.Version = api.Version1_14 | ||
| case api.Version1_14: | ||
| cfg.Metadata.Version = api.Version1_15 | ||
| case api.Version1_15: | ||
| cfg.Metadata.Version = api.Version1_16 | ||
| case api.Version1_16: | ||
| cfg.Metadata.Version = api.Version1_16 | ||
| default: | ||
| // version of control plane is not known to us, maybe we are just too old... | ||
| return fmt.Errorf("control plane version %q is not known to this version of eksctl, try to upgrade eksctl first", currentVersion) | ||
| } | ||
| versionUpdateRequired := cfg.Metadata.Version != currentVersion | ||
|
|
||
| if err := ctl.LoadClusterVPC(cfg); err != nil { | ||
| return errors.Wrapf(err, "getting VPC configuration for cluster %q", cfg.Metadata.Name) | ||
| } | ||
|
|
||
| if err := printer.LogObj(logger.Debug, "cfg.json = \\\n%s\n", cfg); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| stackManager := ctl.NewStackManager(cfg) | ||
|
|
||
| if versionUpdateRequired { | ||
| msgNodeGroupsAndAddons := "you will need to follow the upgrade procedure for all of nodegroups and add-ons" | ||
| cmdutils.LogIntendedAction(cmd.Plan, "upgrade cluster %q control plane from current version %q to %q", cfg.Metadata.Name, currentVersion, cfg.Metadata.Version) | ||
| if !cmd.Plan { | ||
| if err := ctl.UpdateClusterVersionBlocking(cfg); err != nil { | ||
| return err | ||
| } | ||
| logger.Success("cluster %q control plane has been upgraded to version %q", cfg.Metadata.Name, cfg.Metadata.Version) | ||
| logger.Info(msgNodeGroupsAndAddons) | ||
| } | ||
| } | ||
|
|
||
| if err := ctl.RefreshClusterStatus(cfg); err != nil { | ||
| return err | ||
| } | ||
|
|
||
| supportsManagedNodes, err := ctl.SupportsManagedNodes(cfg) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| stackUpdateRequired, err := stackManager.AppendNewClusterStackResource(cmd.Plan, supportsManagedNodes) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| if err := ctl.ValidateExistingNodeGroupsForCompatibility(cfg, stackManager); err != nil { | ||
| logger.Critical("failed checking nodegroups", err.Error()) | ||
| } | ||
|
|
||
| cmdutils.LogPlanModeWarning(cmd.Plan && (stackUpdateRequired || versionUpdateRequired)) | ||
|
|
||
| return nil | ||
| } |
Oops, something went wrong.