| | |
| | | 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 |
| | | } |
| | | |
| | | |