fix #1: using PreKv replace Kv when recieve delete event

wwcd · Sep 5, 2018 · 863b1d1 · 863b1d1
1 parent 42e9c1d
commit 863b1d1
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/cmd/cli/cli.go b/cmd/cli/cli.go
@@ -30,7 +30,7 @@ func main() {
 		panic(err)
 	}
 
-	ticker := time.NewTicker(100 * time.Millisecond)
+	ticker := time.NewTicker(1000 * time.Millisecond)
 	for t := range ticker.C {
 		client := pb.NewGreeterClient(conn)
 		resp, err := client.SayHello(context.Background(), &pb.HelloRequest{Name: "world " + strconv.Itoa(t.Second())})

diff --git a/etcdv3/watcher.go b/etcdv3/watcher.go
@@ -45,15 +45,15 @@ func (w *watcher) Next() ([]*naming.Update, error) {
 
 	// generate etcd Watcher
 	ctx, cancel := context.WithCancel(context.Background())
-	rch := w.client.Watch(ctx, prefix, etcd3.WithPrefix())
+	rch := w.client.Watch(ctx, prefix, etcd3.WithPrefix(), etcd3.WithPrevKV())
 	defer cancel()
 	for wresp := range rch {
 		for _, ev := range wresp.Events {
 			switch ev.Type {
 			case mvccpb.PUT:
 				return []*naming.Update{{Op: naming.Add, Addr: string(ev.Kv.Value)}}, nil
 			case mvccpb.DELETE:
-				return []*naming.Update{{Op: naming.Delete, Addr: string(ev.Kv.Value)}}, nil
+				return []*naming.Update{{Op: naming.Delete, Addr: string(ev.PrevKv.Value)}}, nil
 			}
 		}
 	}