test discov

pkg/discoveryregistry/zookeeper/resolver.go

@@ -39,6 +39,7 @@ func (s *ZkClient) Build(target resolver.Target, cc resolver.ClientConn, opts re
 	s.lock.Lock()
 	defer s.lock.Unlock()
 	s.resolvers[strings.TrimLeft(target.URL.Path, "/")] = r
+	log.ZDebug(context.Background(), "build resolver finished", "target", target, "cc", cc)
 	return r, nil
 }
 

pkg/discoveryregistry/zookeeper/zk.go

@@ -101,11 +101,11 @@ func NewClient(zkServers []string, zkRoot string, options ...ZkOption) (*ZkClien
 		return nil, err
 	}
 	resolver.Register(client)
-	// var wg sync.WaitGroup
+	var wg sync.WaitGroup
-	// wg.Add(2)
+	wg.Add(1)
 	// go client.refresh(&wg)
-	// go client.watch(&wg)
+	go client.watch(&wg)
-	// wg.Wait()
+	wg.Wait()
 	return client, nil
 }