| | |
| | | if event.EventType() == serf.EventMemberLeave { |
| | | if ev.Members !=nil && len(ev.Members) ==1 { |
| | | leaveMember := ev.Members[0] |
| | | leaveSql := "delete from cluster_node where node_id='"+leaveMember.Name+"'" |
| | | leaveSql := "update cluster_node set isDelete=1 where node_id='"+leaveMember.Name+"'" |
| | | ExecuteSqlByGorm([]string{ leaveSql }) |
| | | |
| | | logger.Info("EventMemberLeave,current Members:",ev.Members) |
| | | } |
| | | return |
| | | } else if event.EventType() == serf.EventMemberJoin { |
| | | if ev.Members !=nil && len(ev.Members) ==1 { |
| | | leaveMember := ev.Members[0] |
| | | leaveSql := "update cluster_node set isDelete=0 where node_id='"+leaveMember.Name+"'" |
| | | ExecuteSqlByGorm([]string{ leaveSql }) |
| | | |
| | | logger.Info("EventMemberJoin,current Members:",ev.Members) |
| | | } |
| | | return |
| | | } |
| | |
| | | } |
| | | } |
| | | logger.Info("mbs:",mbs,"a.conf.BindAddr:",a.conf.BindAddr,"specmembername:",specmembername) |
| | | if specmembername == "" {//如果未找到目标节点,说明当前集群内除了本节点,没有其他可用节点 |
| | | return nil,errors.New("specmembername not found") |
| | | } |
| | | |
| | | //query: get db file. |
| | | params := serf.QueryParam{ |