aboutsummaryrefslogtreecommitdiff
path: root/functional_test.go
diff options
context:
space:
mode:
authorBen Johnson <benbjohnson@yahoo.com>2014-02-22 23:08:30 -0700
committerBen Johnson <benbjohnson@yahoo.com>2014-02-23 08:32:53 -0700
commita544249dd8fb2ff76215a2563c2b8f3ab2ccffdb (patch)
treeaf6b03c1922dfd8805b10343a5c52835aa49b743 /functional_test.go
parentRevert "Refactor Transaction/Bucket API." (diff)
downloaddedo-a544249dd8fb2ff76215a2563c2b8f3ab2ccffdb.tar.gz
dedo-a544249dd8fb2ff76215a2563c2b8f3ab2ccffdb.tar.xz
Refactor Bucket.
Diffstat (limited to 'functional_test.go')
-rw-r--r--functional_test.go5
1 files changed, 3 insertions, 2 deletions
diff --git a/functional_test.go b/functional_test.go
index f7c3c3a..61f09bc 100644
--- a/functional_test.go
+++ b/functional_test.go
@@ -56,7 +56,7 @@ func TestParallelTransactions(t *testing.T) {
// Verify all data is in for local data list.
for _, item := range local {
- value, err := txn.Get("widgets", item.Key)
+ value := txn.Bucket("widgets").Get(item.Key)
if !assert.NoError(t, err) || !assert.Equal(t, value, item.Value) {
txn.Close()
wg.Done()
@@ -89,8 +89,9 @@ func TestParallelTransactions(t *testing.T) {
}
// Insert whole batch.
+ b := txn.Bucket("widgets")
for _, item := range batchItems {
- err := txn.Put("widgets", item.Key, item.Value)
+ err := b.Put(item.Key, item.Value)
if !assert.NoError(t, err) {
t.FailNow()
}