Merge pull request #264 from SeanHai/auth

fix generate target.json when curvefs

Author: SeanHai

cli/command/client/map.go

@@ -174,6 +174,9 @@ func genMapPlaybook(curveadm *cli.CurveAdm,
 	steps := MAP_PLAYBOOK_STEPS
 	pb := playbook.NewPlaybook(curveadm)
 	for _, step := range steps {
+		if step == playbook.CREATE_VOLUME && !options.create {
+			continue
+		}
 		pb.AddStep(&playbook.PlaybookStep{
 			Type:    step,
 			Configs: ccs,

internal/configure/monitor.go

@@ -208,7 +208,8 @@ func parsePrometheusTarget(dcs []*topology.DeployConfig) (string, error) {
 		case topology.ROLE_ETCD:
 			item = fmt.Sprintf("%s:%d", ip, dc.GetListenClientPort())
 		case topology.ROLE_MDS,
-			topology.ROLE_CHUNKSERVER:
+			topology.ROLE_CHUNKSERVER,
+			topology.ROLE_METASERVER:
 			item = fmt.Sprintf("%s:%d", ip, dc.GetListenPort())
 		case topology.ROLE_SNAPSHOTCLONE:
 			item = fmt.Sprintf("%s:%d", ip, dc.GetListenDummyPort())

internal/task/task/monitor/sync_config.go

@@ -86,7 +86,7 @@ func NewSyncConfigTask(curveadm *cli.CurveAdm, cfg *configure.MonitorConfig) (*t
 		Lambda: common.CheckContainerExist(cfg.GetHost(), cfg.GetRole(), containerId, &out),
 	})
 	if role == ROLE_PROMETHEUS {
-		t.AddStep(&step.CreateAndUploadDir{ // prepare prometheus conf upath
+		t.AddStep(&step.CreateAndUploadDir{ // prepare prometheus conf path
 			HostDirName:       "prometheus",
 			ContainerDestId:   &containerId,
 			ContainerDestPath: "/etc",