基于serf的数据库同步模块库
liuxiaolong
2019-08-09 1d801237e476f40af8a6974b871afe85cdca5441
agent.go
@@ -178,6 +178,7 @@
            fmt.Println("Query tableNames unmarshal err")
            return
         }
         fmt.Println("Query tableNames:",tableNames)
         datas, err := ExecuteQueryByGorm(tableNames)
         if err !=nil {
            fmt.Println("queryByGorm err")
@@ -422,7 +423,8 @@
   mbs := a.GroupMembers(a.conf.ClusterID)
   var specmembername string
   for _, m := range mbs {
      if m.Addr.String() != a.conf.BindAddr {
      fmt.Println("m",m)
      if m.Name != a.conf.NodeName {
         specmembername = m.Name
         break
      }