liuxiaolong
2020-05-15 ac502c166a6c5523ed8bef9209bf31357e0ddc12
cluster.go
@@ -19,9 +19,12 @@
   dBNameClusterNode  = "cluster_node"
   dBNameTables       = "dbTables"
   dBNameTablePersons = "dbtablepersons"
   dbNameOrg = "org"
   dbNamePerson = "person"
   dbNamePersonIdentity = "person_identity"
)
var syncTables = []string{dBNameCluster, dBNameClusterNode, dBNameTables, dBNameTablePersons}
var syncTables = []string{ dBNameClusterNode, dBNameCluster, dBNameTablePersons, dBNameTables, dbNameOrg, dbNamePersonIdentity, dbNamePerson }
var agent *sdb.Agent
var members *memberlist.Memberlist
var sqliteDBPath string = defaultSqliteDBPath
@@ -108,4 +111,13 @@
      return nil
   }
   return strNodes
}
func GetClusters(key string) []byte  {
   clusters := sdb.CreateSearchNodeWhitClose(key, 2*time.Second);
   clustersJson, err := json.Marshal(clusters)
   if err != nil {
      logger.Error("json.Marshal:", err)
      return nil
   }
   return clustersJson;
}