Merge branch 'master' of https://192.168.1.14/r/ruleprocess
合并把
| | |
|---|
| | | |
|---|
| | | |
|---|
| | | 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) |
|---|
