panlei
2019-08-30 77a05fa27d55ea7e39aee47f71cb5f74308e5e0e
cache/cache.go
@@ -9,6 +9,7 @@
   "fmt"
   "github.com/gogo/protobuf/proto"
   "github.com/satori/go.uuid"
   "ruleprocess/logger"
   "strconv"
)
const (
@@ -18,6 +19,7 @@
   PREFIX_RULE = "RULE_"
   SERVER_KEY = "SERVERINFO"
   PREFIX_SDK = "SDK_"
   PREFIX_SO = "SO"
)
var cMap *shardmap.ShardMap
@@ -53,6 +55,8 @@
   initServerInfo()//初始化服务器配置信息
   initSdks() //初始化sdk列表信息
   initSoData()
   initChan <- true
}
@@ -202,4 +206,23 @@
   } else {
      return sdk,errors.New("sdk not found")
   }
}
func initSoData() {
   var api dbapi.SoApi
   soinfos := api.FindAll()
   logger.Debug("=====================注册表信息:")
   for _,soinfo :=range soinfos {
      logger.Debug(soinfo)
      cMap.Set(PREFIX_SO+soinfo.SdkId,soinfo)
   }
}
func GetSoInfoById(sdkId string) (sdk protomsg.SoInfo,err error){
   obj,b :=cMap.Get(PREFIX_SO + sdkId)
   if b {
      return obj.(protomsg.SoInfo),nil
   } else {
      return sdk,errors.New("sdk not found")
   }
}