From 77a05fa27d55ea7e39aee47f71cb5f74308e5e0e Mon Sep 17 00:00:00 2001 From: panlei <2799247126@qq.com> Date: 星期五, 30 八月 2019 11:08:06 +0800 Subject: [PATCH] stop bigcache init --- cache/cache.go | 23 +++++++++++++++++++++++ 1 files changed, 23 insertions(+), 0 deletions(-) diff --git a/cache/cache.go b/cache/cache.go index a50f676..aeceb67 100644 --- a/cache/cache.go +++ b/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() //鍒濆鍖杝dk鍒楄〃淇℃伅 + + 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") + } } \ No newline at end of file -- Gitblit v1.8.0