基于serf的数据库同步模块库
liuxiaolong
2019-08-09 f5be2d9bc8129ec5877c32749e06ed374462eb79
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,16 +423,18 @@
   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
      }
   }
   fmt.Println(specmembername)
   fmt.Println("mbs:",mbs,"a.conf.BindAddr:",a.conf.BindAddr,"specmembername:",specmembername)
   //query: get db file.
   params := serf.QueryParam{
      FilterNodes: strings.Fields(specmembername),
      //FilterNodes: strings.Fields(specmembername),
      FilterNodes: strings.Fields(a.conf.NodeName),
   }
   //SQL