| | |
| | | "apsClient/serf" |
| | | "apsClient/service/plc_address" |
| | | "fmt" |
| | | "log" |
| | | "net/http" |
| | | "time" |
| | | ) |
| | |
| | | agent.RegisterClusterEvent(serfClusterEvent) |
| | | |
| | | go agent.Serve(serfStartChan) |
| | | if !<-serfStartChan { |
| | | logx.Errorf("serf Init err, exit") |
| | | return |
| | | } |
| | | <-serfStartChan |
| | | //if !<-serfStartChan { |
| | | // logx.Errorf("serf Init err, exit") |
| | | // return |
| | | //} |
| | | |
| | | // 判断当前集群状态 |
| | | logx.Infof("current agent.ClusterStatus:%v", agent.ClusterStatus) |
| | | log.Println("current agent.ClusterStatus:", agent.ClusterStatus) |
| | | if agent.ClusterStatus != "slave" { |
| | | if err := nsq.Init(); err != nil { |
| | | logx.Errorf("nsq Init err:%v", err) |