~jinersong/ruleprocess.git

~jinersong / ruleprocess

派生自 ruleprocess

概况
提交次数
目录
文档
派生
对比

parent: 322b3589 | 补丁 | 提交 | ignore whitespace

cache init

liuxiaolong

2019-07-01 08de038453c4ea9349e6c78b72ca531338d35a12

cache init

1个文件已修改

cache/cache.go

1 ●●●●● 补丁 | 查看 | 原始文档 | blame | 历史

 cache/cache.go

@@ -20,6 +20,7 @@


func Init(initChan chan bool,dbIp string,surveyPort int,pubSubPort int){
    cMap = shardmap.New(uint8(32))
    urlSurvey := "tcp://" + dbIp + ":" + strconv.Itoa(surveyPort)
    urlPubSub := "tcp://" + dbIp + ":" + strconv.Itoa(pubSubPort)
    client, _ := gopherdiscovery.ClientWithSub(urlSurvey, urlPubSub, uuid.NewV4().String())

			@@ -20,6 +20,7 @@


			func Init(initChan chan bool,dbIp string,surveyPort int,pubSubPort int){
			cMap = shardmap.New(uint8(32))
			urlSurvey := "tcp://" + dbIp + ":" + strconv.Itoa(surveyPort)
			urlPubSub := "tcp://" + dbIp + ":" + strconv.Itoa(pubSubPort)
			client, _ := gopherdiscovery.ClientWithSub(urlSurvey, urlPubSub, uuid.NewV4().String())