sunty
2019-07-12 78265dd08a17210ac67c1f82e2514b572c4734c8
esutil/EsClient.go
@@ -12,6 +12,7 @@
   "basic.com/pubsub/protomsg.git"
)
func Parsesources(sources []map[string]interface{}) (esinfos []*protomsg.Esinfo) {
   var ok bool
   for _, source := range sources {
@@ -52,9 +53,8 @@
   }
   return
}
//解析底库人员结构
func Dbpersonbyid(sources []map[string]interface{}) protomsg.Dbperson {
func Dbpersonbyid(sources []map[string]interface{}) (tmpinfos []protomsg.Dbperson) {
   var ok bool
   var tmpinfo protomsg.Dbperson
@@ -115,13 +115,14 @@
      //根据 tableid 获取 tablename
      //name, _:= Dbtablename(tmpinfo.TableId)
      //tmpinfo.TableName= name
            tmpinfos = append(tmpinfos, tmpinfo)
   }
   return tmpinfo
        return tmpinfos
}
//解析底库结构
func Dbtablebyid(sources []map[string]interface{}) protomsg.Dbtable {
func Dbtablebyid(sources []map[string]interface{}) (tmpinfos []protomsg.Dbtable) {
   var ok bool
   var tmpinfo protomsg.Dbtable
@@ -168,9 +169,11 @@
      Isnil("isSync", ok)
      tmpinfo.AnalyServerId, ok = source["analyServerId"].(string)
      Isnil("analyServerId", ok)
        tmpinfos = append(tmpinfos, tmpinfo)
   }
   return tmpinfo
    return tmpinfos
}
func Sourcelist(buf []byte) (sources []map[string]interface{}, err error) {