diff options
author | Ben Johnson <benbjohnson@yahoo.com> | 2014-02-22 22:54:54 -0700 |
---|---|---|
committer | Ben Johnson <benbjohnson@yahoo.com> | 2014-02-22 22:54:54 -0700 |
commit | 3b2fd8f2d3e376fa7a3f3b2ba665fcd4a5b5bb15 (patch) | |
tree | a2b7de98448c4ddd427449dfe85695fa5c7c9c22 /functional_test.go | |
parent | Merge pull request #50 from benbjohnson/api (diff) | |
download | dedo-3b2fd8f2d3e376fa7a3f3b2ba665fcd4a5b5bb15.tar.gz dedo-3b2fd8f2d3e376fa7a3f3b2ba665fcd4a5b5bb15.tar.xz |
Revert "Refactor Transaction/Bucket API."
This reverts commit 1ad2b99f281d587b767b36f886401e81d17915a9.
Diffstat (limited to 'functional_test.go')
-rw-r--r-- | functional_test.go | 9 |
1 files changed, 4 insertions, 5 deletions
diff --git a/functional_test.go b/functional_test.go index acd2f4a..f7c3c3a 100644 --- a/functional_test.go +++ b/functional_test.go @@ -56,15 +56,15 @@ func TestParallelTransactions(t *testing.T) { // Verify all data is in for local data list. for _, item := range local { - value := txn.Bucket("widgets").Get(item.Key) + value, err := txn.Get("widgets", item.Key) if !assert.NoError(t, err) || !assert.Equal(t, value, item.Value) { - txn.Rollback() + txn.Close() wg.Done() t.FailNow() } } - txn.Rollback() + txn.Close() wg.Done() <-readers }() @@ -89,9 +89,8 @@ func TestParallelTransactions(t *testing.T) { } // Insert whole batch. - b := txn.Bucket("widgets") for _, item := range batchItems { - err := b.Put(item.Key, item.Value) + err := txn.Put("widgets", item.Key, item.Value) if !assert.NoError(t, err) { t.FailNow() } |