mirror of
https://github.com/etcd-io/etcd.git
synced 2024-09-27 06:25:44 +00:00
Undo change to Campaign; no need
This commit is contained in:
parent
7e419db4f3
commit
4518b4874e
@ -73,7 +73,7 @@ func (e *Election) Campaign(ctx context.Context, val string) error {
|
|||||||
k := fmt.Sprintf("%s%x", e.keyPrefix, s.Lease())
|
k := fmt.Sprintf("%s%x", e.keyPrefix, s.Lease())
|
||||||
txn := client.Txn(ctx).If(v3.Compare(v3.CreateRevision(k), "=", 0))
|
txn := client.Txn(ctx).If(v3.Compare(v3.CreateRevision(k), "=", 0))
|
||||||
txn = txn.Then(v3.OpPut(k, val, v3.WithLease(s.Lease())))
|
txn = txn.Then(v3.OpPut(k, val, v3.WithLease(s.Lease())))
|
||||||
txn = txn.Else(v3.OpGet(k, v3.WithFirstCreate()...))
|
txn = txn.Else(v3.OpGet(k))
|
||||||
resp, err := txn.Commit()
|
resp, err := txn.Commit()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user