Function startMetanodeInSpecificNode

deploy/cmd/metanode.go:104–150

(node string)

}

func startMetanodeInSpecificNode(node string) error {
	config, err := readConfig()
	if err != nil {
		return err
	}
	files, err := ioutil.ReadDir(ConfDir)
	if err != nil {
		return err
	}

	for _, file := range files {
		if strings.HasPrefix(file.Name(), "metanode") && !file.IsDir() {
			data, err := readMetaNode(ConfDir + "/" + file.Name())
			if err != nil {
				fmt.Printf("Error reading file %s: %s\n", file.Name(), err)
				return nil
			}
			if data.LocalIP == node {
				var dataDir string
				if config.MetaNode.Config.DataDir == "" {
					dataDir = config.Global.DataDir
				} else {
					dataDir = config.MetaNode.Config.DataDir
				}
				confFilePath := ConfDir + "/" + file.Name()
				err = transferConfigFileToRemote(confFilePath, dataDir+"/conf", RemoteUser, node)
				if err != nil {
					return err
				}

				err = checkAndDeleteContainerOnNode(RemoteUser, node, strings.Split(file.Name(), ".")[0])
				if err != nil {
					return err
				}
				status, err := startMetanodeContainerOnNode(RemoteUser, node, strings.Split(file.Name(), ".")[0], dataDir)
				if err != nil {
					return err
				}
				log.Println(status)
				break
			}

		}
	}

	return nil
}

func getMasterAddrAndPort() ([]string, error) {
	config, err := readConfig()