.*: add list-member command

dm/ctl/ctl.go

@@ -76,6 +76,7 @@ func NewRootCmd() *cobra.Command {
 		master.NewMigrateRelayCmd(),
 		master.NewOperateSourceCmd(),
 		master.NewOfflineWorkerCmd(),
+		master.NewListMemberCmd(),
 	)
 	return cmd
 }

dm/ctl/master/list_member.go

@@ -0,0 +1,102 @@
+// Copyright 2019 PingCAP, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+package master
+
+import (
+	"context"
+	"os"
+
+	"github.com/pingcap/errors"
+	"github.com/spf13/cobra"
+
+	"github.com/pingcap/dm/dm/ctl/common"
+	"github.com/pingcap/dm/dm/pb"
+)
+
+var (
+	listMemberFlags = ListMemberFlags{}
+)
+
+// ListMemberFlags are flags that used in ListMember command
+type ListMemberFlags struct {
+	names []string // specify names to list information
+}
+
+// Reset clears cache of ListMemberFlags
+func (c ListMemberFlags) Reset() {
+	c.names = c.names[:0]
+}
+
+// NewListMemberCmd creates an ListMember command
+func NewListMemberCmd() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "list-member [--type leader/master/worker] [--name master-name/worker-name ...]",
+		Short: "list member information",
+		Run:   listMemberFunc,
+	}
+	cmd.Flags().StringP("type", "t", "", "specify a member type from master, worker, and leader")
+	cmd.Flags().StringSliceVarP(&listMemberFlags.names, "name", "n", []string{}, "specify member names in choosing type")
+	return cmd
+}
+
+func convertListMemberType(t string) pb.MemberType {
+	switch t {
+	case "master":
+		return pb.MemberType_MasterType
+	case "worker":
+		return pb.MemberType_WorkerType
+	case "leader":
+		return pb.MemberType_LeaderType
+	case "":
+		return pb.MemberType_AllType
+	default:
+		return pb.MemberType_InvalidType
+	}
+}
+
+// listMemberFunc does list member request
+func listMemberFunc(cmd *cobra.Command, _ []string) {
+	if len(cmd.Flags().Args()) != 0 {
+		cmd.SetOut(os.Stdout)
+		cmd.Usage()
+		return
+	}
+
+	member, err := cmd.Flags().GetString("type")
+	if err != nil {
+		common.PrintLines("%s", errors.ErrorStack(err))
+		return
+	}
+
+	memType := convertListMemberType(member)
+	if memType == pb.MemberType_InvalidType {
+		common.PrintLines("invalid type '%s', choose from master, worker, and leader", member)
+		return
+	}
+
+	ctx, cancel := context.WithCancel(context.Background())
+	defer cancel()
+
+	cli := common.MasterClient()
+	resp, err := cli.ListMember(ctx, &pb.ListMemberRequest{
+		MemType: memType,
+		Names:   listMemberFlags.names,
+	})
+
+	if err != nil {
+		common.PrintLines("list member failed, error:\n%v", errors.ErrorStack(err))
+		return
+	}
+	common.PrettyPrintResponse(resp)
+}

dm/master/scheduler/scheduler.go

@@ -573,6 +573,22 @@ func (s *Scheduler) RemoveWorker(name string) error {
 	return nil
 }
 
+// GetAllWorkers gets all worker agent.
+func (s *Scheduler) GetAllWorkers() ([]*Worker, error) {
+	s.mu.RLock()
+	defer s.mu.RUnlock()
+
+	if !s.started {
+		return nil, terror.ErrSchedulerNotStarted.Generate()
+	}
+
+	workers := make([]*Worker, 0, len(s.workers))
+	for _, value := range s.workers {
+		workers = append(workers, value)
+	}
+	return workers, nil
+}
+
 // GetWorkerByName gets worker agent by worker name.
 func (s *Scheduler) GetWorkerByName(name string) *Worker {
 	s.mu.RLock()

dm/master/server.go

@@ -1559,3 +1559,166 @@ func (s *Server) getSourceRespsAfterOperation(ctx context.Context, taskName stri
 	wg.Wait()
 	return sortCommonWorkerResults(sourceRespCh)
 }
+
+func (s *Server) listMemberMaster(ctx context.Context, names []string) (*pb.Members_Master, error) {
+
+	resp := &pb.Members_Master{
+		Master: &pb.ListMasterMember{},
+	}
+
+	memberList, err := s.etcdClient.MemberList(ctx)
+	if err != nil {
+		resp.Master.Msg = errors.ErrorStack(err)
+		return resp, nil
+	}
+
+	all := len(names) == 0
+	set := make(map[string]bool)
+	for _, name := range names {
+		set[name] = true
+	}
+
+	etcdMembers := memberList.Members
+	masters := make([]*pb.MasterInfo, 0, len(etcdMembers))
+	client := http.Client{
+		Timeout: 1 * time.Second,
+	}
+
+	for _, etcdMember := range etcdMembers {
+		if !all && !set[etcdMember.Name] {
+			continue
+		}
+
+		alive := true
+		_, err := client.Get(etcdMember.ClientURLs[0] + "/health")
+		if err != nil {
+			alive = false
+		}
+
+		masters = append(masters, &pb.MasterInfo{
+			Name:       etcdMember.Name,
+			MemberID:   etcdMember.ID,
+			Alive:      alive,
+			ClientURLs: etcdMember.ClientURLs,
+			PeerURLs:   etcdMember.PeerURLs,
+		})
+	}
+
+	resp.Master.Masters = masters
+	return resp, nil
+}
+
+func (s *Server) listMemberWorker(ctx context.Context, names []string) (*pb.Members_Worker, error) {
+	resp := &pb.Members_Worker{
+		Worker: &pb.ListWorkerMember{},
+	}
+
+	workerAgents, err := s.scheduler.GetAllWorkers()
+	if err != nil {
+		resp.Worker.Msg = errors.ErrorStack(err)
+		return resp, nil
+	}
+
+	all := len(names) == 0
+	set := make(map[string]bool)
+	for _, name := range names {
+		set[name] = true
+	}
+
+	workers := make([]*pb.WorkerInfo, 0, len(workerAgents))
+
+	for _, workerAgent := range workerAgents {
+		if !all && !set[workerAgent.BaseInfo().Name] {
+			continue
+		}
+
+		workers = append(workers, &pb.WorkerInfo{
+			Name:   workerAgent.BaseInfo().Name,
+			Addr:   workerAgent.BaseInfo().Addr,
+			Stage:  string(workerAgent.Stage()),
+			Source: workerAgent.Bound().Source,
+		})
+	}
+
+	resp.Worker.Workers = workers
+	return resp, nil
+}
+
+func (s *Server) listMemberLeader(ctx context.Context, names []string) (*pb.Members_Leader, error) {
+	resp := &pb.Members_Leader{
+		Leader: &pb.ListLeaderMember{},
+	}
+
+	all := len(names) == 0
+	set := make(map[string]bool)
+	for _, name := range names {
+		set[name] = true
+	}
+
+	_, name, addr, err := s.election.LeaderInfo(ctx)
+	if err != nil {
+		resp.Leader.Msg = errors.ErrorStack(err)
+		return resp, nil
+	}
+
+	if !all && !set[name] {
+		return resp, nil
+	}
+
+	resp.Leader.Name = name
+	resp.Leader.Addr = addr
+	return resp, nil
+}
+
+// ListMember list member information
+func (s *Server) ListMember(ctx context.Context, req *pb.ListMemberRequest) (*pb.ListMemberResponse, error) {
+	log.L().Info("", zap.Stringer("payload", req), zap.String("request", "ListMember"))
+
+	isLeader, needForward := s.isLeaderAndNeedForward()
+	if !isLeader {
+		if needForward {
+			return s.leaderClient.ListMember(ctx, req)
+		}
+		return nil, terror.ErrMasterRequestIsNotForwardToLeader
+	}
+
+	resp := &pb.ListMemberResponse{}
+	members := make([]*pb.Members, 0)
+
+	if req.MemType == pb.MemberType_AllType || req.MemType == pb.MemberType_MasterType {
+		res, err := s.listMemberMaster(ctx, req.Names)
+		if err != nil {
+			resp.Msg = errors.ErrorStack(err)
+			return resp, nil
+		}
+		members = append(members, &pb.Members{
+			Member: res,
+		})
+	}
+
+	if req.MemType == pb.MemberType_AllType || req.MemType == pb.MemberType_WorkerType {
+		res, err := s.listMemberWorker(ctx, req.Names)
+		if err != nil {
+			resp.Msg = errors.ErrorStack(err)
+			return resp, nil
+		}
+		members = append(members, &pb.Members{
+			Member: res,
+		})
+	}
+
+	if req.MemType == pb.MemberType_AllType || req.MemType == pb.MemberType_LeaderType {
+		res, err := s.listMemberLeader(ctx, req.Names)
+		if err != nil {
+			resp.Msg = errors.ErrorStack(err)
+			return resp, nil
+		}
+		members = append(members, &pb.Members{
+			Member: res,
+		})
+	}
+
+	resp.Result = true
+	resp.Members = members
+	return resp, nil
+}