Mirroristas/etcd
2
0
Fork 0
mirror of https://github.com/etcd-io/etcd.git synced 2024-09-27 06:25:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #4617 from gyuho/txn_example

Browse Source 
clientv3: fix txn example code
This commit is contained in:
Gyu-Ho Lee 2016-02-25 12:22:34 -07:00
commit 6a97c967cc
1 changed files with 15 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

25
clientv3/example_kv_test.go
View File

@ -170,19 +170,23 @@ func ExampleKV_txn() {
kvc := clientv3.NewKV(cli)
// TODO: 'if' not working. Add expected output once fixed.
ctx, cancel := context.WithTimeout(context.Background(), requestTimeout)
_, err = kvc.Txn(ctx).
If(clientv3.Compare(clientv3.Value("1"), ">", "1")).
Then(clientv3.OpPut("1", "100")).
Else(clientv3.OpPut("1", "-1")).
Commit()
cancel()
if err == nil {
_, err = kvc.Put(context.TODO(), "key", "xyz")
if err != nil {
log.Fatal(err)
}
gresp, err := kvc.Get(ctx, "1")
ctx, cancel := context.WithTimeout(context.Background(), requestTimeout)
_, err = kvc.Txn(ctx).
If(clientv3.Compare(clientv3.Value("key"), ">", "abc")). // txn value comparisons are lexical
Then(clientv3.OpPut("key", "XYZ")). // this runs, since 'xyz' > 'abc'
Else(clientv3.OpPut("key", "ABC")).
Commit()
cancel()
if err != nil {
log.Fatal(err)
}
gresp, err := kvc.Get(context.TODO(), "key")
cancel()
if err != nil {
log.Fatal(err)
@ -190,4 +194,5 @@ func ExampleKV_txn() {
for _, ev := range gresp.Kvs {
fmt.Printf("%s : %s\n", ev.Key, ev.Value)
}
// key : XYZ
}