Refactor code

This commit is contained in:
wenxu12345
2022-02-11 18:49:17 +08:00
parent 63af591938
commit af330d7f8a
4 changed files with 165 additions and 174 deletions
+4 -5
View File
@@ -37,8 +37,7 @@ func RegisterEtcd4Unique(schema, etcdAddr, myHost string, myPort int, serviceNam
//etcdAddr separated by commas
func RegisterEtcd(schema, etcdAddr, myHost string, myPort int, serviceName string, ttl int) error {
cli, err := clientv3.New(clientv3.Config{
Endpoints: strings.Split(etcdAddr, ","),
})
Endpoints: strings.Split(etcdAddr, ","), DialTimeout: 5 * time.Second})
fmt.Println("RegisterEtcd")
if err != nil {
// return fmt.Errorf("grpclb: create clientv3 client failed: %v", err)
@@ -68,13 +67,13 @@ func RegisterEtcd(schema, etcdAddr, myHost string, myPort int, serviceName strin
}
fmt.Println("RegisterEtcd ok")
go func() {
FLOOP:
for {
select {
case _, ok := <-kresp:
case v, ok := <-kresp:
if ok == true {
fmt.Println(" kresp ok ", v)
} else {
break FLOOP
fmt.Println(" kresp failed ", v)
}
}
}