| | |
|---|
| | | } |
|---|
| | | case serf.MemberEvent: |
|---|
| | | 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+"'" |
|---|
| | | ExecuteSqlByGorm([]string{ leaveSql }) |
|---|
| | | |
|---|
| | | fmt.Println("EventMemberLeave,current Members:",ev.Members) |
|---|
| | | fmt.Printf("event.EventType() == serf.EventMemberLeave") |
|---|
| | | return |
|---|
| | | }else{ |
|---|
| | | fmt.Println("MemberEvent other,current Members:",ev.Members) |
|---|
| | | fmt.Printf("event.EventType() == serf.other") |
|---|
| | | } |
|---|
| | | return |
|---|
| | | } |
|---|
| | | |
|---|
