diff --git a/etcdv3/naming.go b/etcdv3/naming.go index 4063847..51db1e2 100644 --- a/etcdv3/naming.go +++ b/etcdv3/naming.go @@ -63,11 +63,6 @@ func withAlive(name string, addr string, ttl int64) error { if err != nil { return err } - - _, err = cli.KeepAlive(context.Background(), leaseResp.ID) - if err != nil { - return err - } return nil } diff --git a/etcdv3/resolver.go b/etcdv3/resolver.go index 6592fbc..01702c2 100644 --- a/etcdv3/resolver.go +++ b/etcdv3/resolver.go @@ -14,7 +14,6 @@ import ( "time" "github.com/coreos/etcd/clientv3" - "github.com/coreos/etcd/mvcc/mvccpb" "google.golang.org/grpc/resolver" ) @@ -84,12 +83,12 @@ func (r *etcdResolver) watch(keyPrefix string) { for _, ev := range n.Events { addr := strings.TrimPrefix(string(ev.Kv.Key), keyPrefix) switch ev.Type { - case mvccpb.PUT: + case clientv3.EventTypePut: if !exist(addrList, addr) { addrList = append(addrList, resolver.Address{Addr: addr}) r.cc.NewAddress(addrList) } - case mvccpb.DELETE: + case clientv3.EventTypeDelete: if s, ok := remove(addrList, addr); ok { addrList = s r.cc.NewAddress(addrList)