This commit is contained in:
yangzhouhan
2015-08-07 17:15:27 -07:00
parent 2e3fbc4f8f
commit 6970805cc5
2 changed files with 3 additions and 10 deletions

View File

@ -107,10 +107,6 @@ func (nr *etcdNR) Get(target string) map[string]string {
} }
res := make(map[string]string) res := make(map[string]string)
getNode(resp.Node, res) getNode(resp.Node, res)
for k,v := range res {
fmt.Println("key is :",k,"value is :",v)}
return res return res
} }
@ -138,8 +134,8 @@ func (nr *etcdNR) GetUpdate() (string, string) {
case i := <-nr.recv.get(): case i := <-nr.recv.get():
nr.recv.load() nr.recv.load()
if i == nil { if i == nil {
return "","" return "", ""
} }
// returns key and the corresponding value of the updated kv // returns key and the corresponding value of the updated kv
return i.key, i.value return i.key, i.value
} }
@ -149,5 +145,3 @@ func (nr *etcdNR) Stop() {
nr.recv.stop() nr.recv.stop()
nr.cancel() nr.cancel()
} }

View File

@ -1,4 +1,4 @@
package naming; package naming
// Resolver dose name resolution and watches for the resolution changes. // Resolver dose name resolution and watches for the resolution changes.
type Resolver interface { type Resolver interface {
@ -11,4 +11,3 @@ type Resolver interface {
// Stop shuts down the NameResolver. // Stop shuts down the NameResolver.
Stop() Stop()
} }