派生自 ruleprocess
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
panlei
2019-07-02 78592c305ecd3471ba155de84dc391b1c9b12384 
 cache/cache.go


@@ -20,8 +20,9 @@






func Init(initChan chan bool,dbIp string,surveyPort int,pubSubPort int){


   urlSurvey := dbIp + strconv.Itoa(surveyPort)


   urlPubSub := dbIp + strconv.Itoa(pubSubPort)


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


   recvMsg := client.HeartBeatMsg()


   fmt.Println(<-recvMsg)