diff --git a/etcd.go b/etcd.go index a3db378..c6ff5c4 100644 --- a/etcd.go +++ b/etcd.go @@ -43,8 +43,8 @@ func NewEtcd(config *EtcdConfig) *Etcd { } // Watch 监听 -func (e Etcd) Watch(ctx context.Context, key string) clientv3.WatchChan { - return e.c.Watch(ctx, key) // type WatchChan <-chan WatchResponse +func (e Etcd) Watch(ctx context.Context, key string, opts ...clientv3.OpOption) clientv3.WatchChan { + return e.c.Watch(ctx, key, opts...) } // Create 创建 diff --git a/version.go b/version.go index d119ead..562292b 100644 --- a/version.go +++ b/version.go @@ -1,3 +1,3 @@ package gojobs -const Version = "1.0.5" +const Version = "1.0.6"