cache init

liuxiaolong

2019-07-01 08de038453c4ea9349e6c78b72ca531338d35a12

 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())