aboutsummaryrefslogtreecommitdiff
path: root/functional_test.go
diff options
context:
space:
mode:
authorBen Johnson <benbjohnson@yahoo.com>2014-02-22 22:54:54 -0700
committerBen Johnson <benbjohnson@yahoo.com>2014-02-22 22:54:54 -0700
commit3b2fd8f2d3e376fa7a3f3b2ba665fcd4a5b5bb15 (patch)
treea2b7de98448c4ddd427449dfe85695fa5c7c9c22 /functional_test.go
parentMerge pull request #50 from benbjohnson/api (diff)
downloaddedo-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.go9
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()
}