diff --git a/middleware/etcd/watch.go b/middleware/etcd/watch.go index e080d55..22ecc6a 100644 --- 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)