3 Copyright © 2019 NAME HERE <EMAIL ADDRESS>
5 Licensed under the Apache License, Version 2.0 (the "License");
6 you may not use this file except in compliance with the License.
7 You may obtain a copy of the License at
9 http://www.apache.org/licenses/LICENSE-2.0
11 Unless required by applicable law or agreed to in writing, software
12 distributed under the License is distributed on an "AS IS" BASIS,
13 WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 See the License for the specific language governing permissions and
15 limitations under the License.
23 "github.com/spf13/cobra"
24 "github.com/spf13/pflag"
25 types "elcli/cmd/common"
29 var joinOptions = &types.JoinOptions{}
31 // joinCmd represents the join command
32 var joinCmd = &cobra.Command{
34 Short: "A brief description of your command",
35 Long: `A longer description that spans multiple lines and likely contains examples
36 and usage of using your command. For example:
38 Cobra is a CLI library for Go that empowers applications.
39 This application is a tool to generate the needed files
40 to quickly create a Cobra application.`,
42 RunE: func(cmd *cobra.Command, args []string) error {
43 fmt.Println("join called")
45 tools := make(map[string]types.ToolsInstaller, 0)
46 flagVals := make(map[string]types.FlagData, 0)
48 checkFlags := func(f *pflag.Flag) {
49 util.AddToolVals(f, flagVals)
51 cmd.Flags().VisitAll(checkFlags)
53 //joinOptions := &types.JoinOptions{}
54 joinOptions = newJoinOptions()
56 Add2ToolsList(tools, flagVals, joinOptions)
57 return ExecuteTool(tools)
64 // Join Command added as sub-command for main command : elcli
65 rootCmd.AddCommand(joinCmd)
67 joinCmd.Flags().StringVar(&joinOptions.DockerVersion, types.DockerVersion, joinOptions.DockerVersion,
68 "Use this key to download and use the required Docker version")
69 joinCmd.Flags().Lookup(types.DockerVersion).NoOptDefVal = joinOptions.DockerVersion
71 joinCmd.Flags().StringVar(&joinOptions.KubernetesVersion, types.KubernetesVersion, joinOptions.KubernetesVersion,
72 "Use this key to download and use the required Kubernetes version")
73 joinCmd.Flags().Lookup(types.KubernetesVersion).NoOptDefVal = joinOptions.KubernetesVersion
75 joinCmd.Flags().StringVar(&joinOptions.K8SImageRepository, types.K8SImageRepository, joinOptions.K8SImageRepository,
76 "Use this key to set the Kubernetes docker image repository")
77 joinCmd.Flags().Lookup(types.K8SImageRepository).NoOptDefVal = joinOptions.K8SImageRepository
82 func newJoinOptions() *types.JoinOptions {
83 fmt.Println("Inside newJointOptions Method.....")
84 opts := &types.JoinOptions{}
85 opts.InitOptions = types.InitOptions{DockerVersion: types.DefaultDockerVersion, KubernetesVersion: types.DefaultK8SVersion}
86 //opts.CertPath = types.DefaultCertPath
91 //Add2ToolsList Reads the flagData (containing val and default val) and join options to fill the list of tools.
92 func Add2ToolsList(toolList map[string]types.ToolsInstaller, flagData map[string]types.FlagData, joinOptions *types.JoinOptions) {
94 var k8sVer, dockerVer string
95 /*var k8sImageRepo string
97 flgData, ok := flagData[types.K8SImageRepository]
99 k8sImageRepo = util.CheckIfAvailable(flgData.Val.(string), flgData.DefVal.(string))
101 k8sImageRepo = joinOptions.K8SImageRepository
106 //toolList["EliotEdge"] = &util.KubeEdgeInstTool{Common: util.Common{ToolVersion: kubeVer}, K8SApiServerIP: joinOptions.K8SAPIServerIPPort,
107 // CloudCoreIP: joinOptions.CloudCoreIP, EdgeNodeID: joinOptions.EdgeNodeID}
109 flgData, ok := flagData[types.DockerVersion]
111 dockerVer = util.CheckIfAvailable(flgData.Val.(string), flgData.DefVal.(string))
113 dockerVer = joinOptions.DockerVersion
115 toolList["Docker"] = &util.DockerInstTool{Common: util.Common{ToolVersion: dockerVer}, DefaultToolVer: flgData.DefVal.(string)}
118 flgData, ok = flagData[types.KubernetesVersion]
120 k8sVer = util.CheckIfAvailable(flgData.Val.(string), flgData.DefVal.(string))
122 k8sVer = joinOptions.KubernetesVersion
124 toolList["Kubernetes"] = &util.K8SInstTool{Common: util.Common{ToolVersion: k8sVer}, IsEdgeNode: false, DefaultToolVer: flgData.DefVal.(string)}
129 //ExecuteTool the instalation for each tool and start edgecore
130 func ExecuteTool(toolList map[string]types.ToolsInstaller) error {
132 //Install all the required pre-requisite tools
133 for name, tool := range toolList {
134 if name != "EliotEdge" {
135 err := tool.InstallTools()
142 //Install and Start ElioteEdge Node
143 return toolList["ElioteEdge"].InstallTools()