From a7bdf872b7477a858ea312ceeab3c25caa585111 Mon Sep 17 00:00:00 2001 From: liuxiaolong <736321739@qq.com> Date: 星期三, 13 五月 2020 20:46:02 +0800 Subject: [PATCH] -- --- cluster.go | 15 ++++++++++++++- 1 files changed, 14 insertions(+), 1 deletions(-) diff --git a/cluster.go b/cluster.go index ee96790..4f8de28 100644 --- a/cluster.go +++ b/cluster.go @@ -19,9 +19,13 @@ dBNameClusterNode = "cluster_node" dBNameTables = "dbTables" dBNameTablePersons = "dbtablepersons" + dbNameOrg = "org" + dbNamePerson = "person" + dbNamePersonCameraImagePath = "person_camera_image_path" + dbNamePersonIdentity = "person_identity" ) -var syncTables = []string{dBNameCluster, dBNameClusterNode, dBNameTables, dBNameTablePersons} +var syncTables = []string{ dBNameClusterNode, dBNameCluster, dBNameTablePersons, dBNameTables, dbNameOrg, dbNamePersonCameraImagePath, dbNamePersonIdentity, dbNamePerson } var agent *sdb.Agent var members *memberlist.Memberlist var sqliteDBPath string = defaultSqliteDBPath @@ -108,4 +112,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; } \ No newline at end of file -- Gitblit v1.8.0