zhangqian
2023-10-21 2ea23e2364f742f528fb8b97657212c174d1bbd7
main.go
@@ -39,16 +39,19 @@
      "production_progress",
      "work_order",
      "task_status_sync",
      "device",
      "device_plc",
   }
   agent := serf.InitAgent("apsClient", syncTables, sqlitex.GetDB())
   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)