dev-v2.0.0: fix missing arg to install containerd

Signed-off-by: 24sama <leo@kubesphere.io>

cmd/add_nodes.go

@@ -27,12 +27,13 @@ var addNodesCmd = &cobra.Command{
 	Short: "Add nodes to the cluster according to the new nodes information from the specified configuration file",
 	RunE: func(cmd *cobra.Command, args []string) error {
 		arg := common.Argument{
-			FilePath:       opt.ClusterCfgFile,
-			KsEnable:       false,
-			Debug:          opt.Verbose,
-			SkipCheck:      opt.SkipCheck,
-			SkipPullImages: opt.SkipPullImages,
-			InCluster:      opt.InCluster,
+			FilePath:         opt.ClusterCfgFile,
+			KsEnable:         false,
+			Debug:            opt.Verbose,
+			SkipCheck:        opt.SkipCheck,
+			SkipPullImages:   opt.SkipPullImages,
+			InCluster:        opt.InCluster,
+			ContainerManager: opt.ContainerManager,
 		}
 		return pipelines.AddNodes(arg, opt.DownloadCmd)
 	},

cmd/cluster.go

@@ -47,6 +47,7 @@ var clusterCmd = &cobra.Command{
 			InCluster:          opt.InCluster,
 			DeployLocalStorage: opt.LocalStorage,
 			Debug:              opt.Verbose,
+			ContainerManager:   opt.ContainerManager,
 		}
 
 		return pipelines.CreateCluster(arg, opt.DownloadCmd)
@@ -62,6 +63,7 @@ func init() {
 	clusterCmd.Flags().BoolVarP(&opt.Kubesphere, "with-kubesphere", "", false, "Deploy a specific version of kubesphere (default v3.1.0)")
 	clusterCmd.Flags().BoolVarP(&opt.SkipCheck, "yes", "y", false, "Skip pre-check of the installation")
 	clusterCmd.Flags().BoolVarP(&opt.SkipPullImages, "skip-pull-images", "", false, "Skip pre pull images")
+	clusterCmd.Flags().StringVarP(&opt.ContainerManager, "container-manager", "", "docker", "Container runtime: docker, crio, containerd and isula.")
 	clusterCmd.Flags().StringVarP(&opt.DownloadCmd, "download-cmd", "", "curl -L -o %s %s",
 		`The user defined command to download the necessary binary files. The first param '%s' is output path, the second param '%s', is the URL`)
 

pkg/pipelines/bootstrap/os/module.go

@@ -125,7 +125,7 @@ func (i *InitDependenciesModule) Init() {
 
 	offlineInstall := &modules.RemoteTask{
 		Name:     "OnlineInstallDependencies",
-		Desc:     "Online install dependencies",
+		Desc:     "Offline install dependencies",
 		Hosts:    i.Runtime.GetAllHosts(),
 		Action:   new(OfflineInstallDependencies),
 		Parallel: true,

pkg/pipelines/common/kube_runtime.go

@@ -33,6 +33,7 @@ type Argument struct {
 	SourcesDir         string
 	DownloadCommand    func(path, url string) string
 	InCluster          bool
+	ContainerManager   string
 }
 
 func NewKubeRuntime(flag string, arg Argument) (*KubeRuntime, error) {