update

2021-11-26 15:56:30 +08:00 · 2021-11-26 15:56:30 +08:00 · 34c9f035ee
commit 34c9f035ee
parent 628eac60b4
1 changed files with 1 additions and 1 deletions
--- a/middleware/etcd/watch.go
+++ b/middleware/etcd/watch.go
@ -29,7 +29,7 @@ func WatchKeyWithOption(ctx context.Context, watchKey string, callbackFunc Watch
 		ctx = context.Background()
 	}

-	rch := Client.Watch(ctx, watchKey) // <-chan WatchResponse
+	rch := Client.Watch(ctx, watchKey, optionList...) // <-chan WatchResponse
 	for watchResp := range rch {
 		for _, ev := range watchResp.Events {
 			callbackFunc(ev)