diff --git a/contrib/recipes/barrier.go b/contrib/recipes/barrier.go index 6e9281721..666c7424c 100644 --- a/contrib/recipes/barrier.go +++ b/contrib/recipes/barrier.go @@ -36,7 +36,7 @@ func NewBarrier(client *v3.Client, key string) *Barrier { // Hold creates the barrier key causing processes to block on Wait. func (b *Barrier) Hold() error { - _, err := newKey(b.client, b.key, 0) + _, err := newKey(b.client, b.key, v3.NoLease) return err } diff --git a/contrib/recipes/key.go b/contrib/recipes/key.go index aea00059a..2d5a32f84 100644 --- a/contrib/recipes/key.go +++ b/contrib/recipes/key.go @@ -47,7 +47,7 @@ func newKV(kv v3.KV, key, val string, leaseID v3.LeaseID) (*RemoteKV, error) { func newUniqueKV(kv v3.KV, prefix string, val string) (*RemoteKV, error) { for { newKey := fmt.Sprintf("%s/%v", prefix, time.Now().UnixNano()) - rev, err := putNewKV(kv, newKey, val, 0) + rev, err := putNewKV(kv, newKey, val, v3.NoLease) if err == nil { return &RemoteKV{kv, newKey, rev, val}, nil }