main.go
@@ -30,6 +30,7 @@ // 启动数据同步 var serfStartChan = make(chan bool) // 需要同步的表 var syncTables = []string{ "procedures", @@ -41,8 +42,12 @@ agent := serf.InitAgent("apsClient", syncTables, sqlitex.GetDB()) agent.RegisterClusterEvent(serfClusterEvent) go agent.Serve(serfStartChan) <-serfStartChan if !<-serfStartChan { logx.Errorf("serf Init err, exit") return } // 判断当前集群状态 if agent.ClusterStatus != "slave" {
