aboutsummaryrefslogtreecommitdiff
path: root/tests/dedo.go
diff options
context:
space:
mode:
Diffstat (limited to 'tests/dedo.go')
-rw-r--r--tests/dedo.go236
1 files changed, 118 insertions, 118 deletions
diff --git a/tests/dedo.go b/tests/dedo.go
index 5032f01..b5dec6e 100644
--- a/tests/dedo.go
+++ b/tests/dedo.go
@@ -540,7 +540,7 @@ func TestBucket_Get_NonExistent(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -564,7 +564,7 @@ func TestBucket_Get_FromNode(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -593,7 +593,7 @@ func TestBucket_Get_IncompatibleValue(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -628,7 +628,7 @@ func TestBucket_Get_Capacity(t *testing.T) {
defer os.Remove(db.Path())
// Write key to a bucket.
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("bucket"))
if err != nil {
return err
@@ -641,7 +641,7 @@ func TestBucket_Get_Capacity(t *testing.T) {
}
// Retrieve value and attempt to append to it.
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
k, v := tx.Bucket([]byte("bucket")).Cursor().First()
// Verify capacity.
@@ -668,7 +668,7 @@ func TestBucket_Put(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -697,7 +697,7 @@ func TestBucket_Put_Repeat(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -732,7 +732,7 @@ func TestBucket_Put_Large(t *testing.T) {
defer os.Remove(db.Path())
count, factor := 100, 200
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -786,7 +786,7 @@ func TestDB_Put_VeryLarge(t *testing.T) {
defer os.Remove(db.Path())
for i := 0; i < n; i += batchN {
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucketIfNotExists([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -813,7 +813,7 @@ func TestBucket_Put_IncompatibleValue(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b0, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -872,7 +872,7 @@ func TestBucket_Put_ReadOnly(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -904,7 +904,7 @@ func TestBucket_Delete(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -938,7 +938,7 @@ func TestBucket_Delete_Large(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -960,7 +960,7 @@ func TestBucket_Delete_Large(t *testing.T) {
t.Fatal(err)
}
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
b := tx.Bucket([]byte("widgets"))
for i := 0; i < 100; i++ {
err := b.Delete([]byte(strconv.Itoa(i)))
@@ -1003,7 +1003,7 @@ func TestBucket_Delete_FreelistOverflow(t *testing.T) {
k := make([]byte, 16)
for i := uint64(0); i < n1; i++ {
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucketIfNotExists([]byte("0"))
if err != nil {
t.Fatalf("bucket error: %s", err)
@@ -1026,7 +1026,7 @@ func TestBucket_Delete_FreelistOverflow(t *testing.T) {
}
// Delete all of them in one large transaction
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b := tx.Bucket([]byte("0"))
c := b.Cursor()
for k, _ := c.First(); k != nil; k, _ = c.Next() {
@@ -1048,7 +1048,7 @@ func TestBucket_Nested(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
// Create a widgets bucket.
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
@@ -1075,7 +1075,7 @@ func TestBucket_Nested(t *testing.T) {
db.MustCheck()
// Update widgets/bar.
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
b := tx.Bucket([]byte("widgets"))
err := b.Put([]byte("bar"), []byte("xxxx"))
if err != nil {
@@ -1090,7 +1090,7 @@ func TestBucket_Nested(t *testing.T) {
db.MustCheck()
// Cause a split.
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
b := tx.Bucket([]byte("widgets"))
for i := 0; i < 10000; i++ {
err := b.Put(
@@ -1110,7 +1110,7 @@ func TestBucket_Nested(t *testing.T) {
db.MustCheck()
// Insert into widgets/foo/baz.
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
b := tx.Bucket([]byte("widgets"))
err := b.Bucket([]byte("foo")).Put(
[]byte("baz"),
@@ -1160,7 +1160,7 @@ func TestBucket_Delete_Bucket(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -1189,7 +1189,7 @@ func TestBucket_Delete_ReadOnly(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -1248,7 +1248,7 @@ func TestBucket_DeleteBucket_Nested(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
widgets, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -1288,7 +1288,7 @@ func TestBucket_DeleteBucket_Nested2(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
widgets, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -1314,7 +1314,7 @@ func TestBucket_DeleteBucket_Nested2(t *testing.T) {
t.Fatal(err)
}
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
widgets := tx.Bucket([]byte("widgets"))
if widgets == nil {
t.Fatal("expected widgets bucket")
@@ -1365,7 +1365,7 @@ func TestBucket_DeleteBucket_Large(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
widgets, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -1391,7 +1391,7 @@ func TestBucket_DeleteBucket_Large(t *testing.T) {
t.Fatal(err)
}
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
err := tx.DeleteBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -1410,7 +1410,7 @@ func TestBucket_Bucket_IncompatibleValue(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
widgets, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -1439,7 +1439,7 @@ func TestBucket_CreateBucket_IncompatibleValue(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
widgets, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -1468,7 +1468,7 @@ func TestBucket_DeleteBucket_IncompatibleValue(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
widgets, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -1497,7 +1497,7 @@ func TestBucket_NextSequence(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
widgets, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -1546,7 +1546,7 @@ func TestBucket_NextSequence_Persist(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -1558,7 +1558,7 @@ func TestBucket_NextSequence_Persist(t *testing.T) {
t.Fatal(err)
}
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
_, err := tx.Bucket([]byte("widgets")).NextSequence()
if err != nil {
t.Fatal(err)
@@ -1570,7 +1570,7 @@ func TestBucket_NextSequence_Persist(t *testing.T) {
t.Fatal(err)
}
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
seq, err := tx.Bucket([]byte("widgets")).NextSequence()
if err != nil {
t.Fatalf("unexpected error: %s", err)
@@ -1592,7 +1592,7 @@ func TestBucket_NextSequence_ReadOnly(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -1651,7 +1651,7 @@ func TestBucket_ForEach(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -1719,7 +1719,7 @@ func TestBucket_ForEach_ShortCircuit(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -1797,7 +1797,7 @@ func TestBucket_Put_EmptyKey(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -1826,7 +1826,7 @@ func TestBucket_Put_KeyTooLarge(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -1849,7 +1849,7 @@ func TestBucket_Put_ValueTooLarge(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -1882,7 +1882,7 @@ func TestBucket_Put_Single(t *testing.T) {
m := make(map[string][]byte)
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -1895,7 +1895,7 @@ func TestBucket_Put_Single(t *testing.T) {
}
for _, item := range items {
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
err := tx.Bucket([]byte("widgets")).Put(
item.Key,
item.Value,
@@ -1963,7 +1963,7 @@ func TestBucket_Put_Multiple(t *testing.T) {
defer os.Remove(db.Path())
// Bulk insert all values.
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -1975,7 +1975,7 @@ func TestBucket_Put_Multiple(t *testing.T) {
t.Fatal(err)
}
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
b := tx.Bucket([]byte("widgets"))
for _, item := range items {
err := b.Put(item.Key, item.Value)
@@ -2030,7 +2030,7 @@ func TestBucket_Delete_Quick(t *testing.T) {
defer os.Remove(db.Path())
// Bulk insert all values.
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -2042,7 +2042,7 @@ func TestBucket_Delete_Quick(t *testing.T) {
t.Fatal(err)
}
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
b := tx.Bucket([]byte("widgets"))
for _, item := range items {
err := b.Put(item.Key, item.Value)
@@ -2059,7 +2059,7 @@ func TestBucket_Delete_Quick(t *testing.T) {
// Remove items one at a time and check consistency.
for _, item := range items {
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
return tx.Bucket([]byte("widgets")).Delete(
item.Key,
)
@@ -2106,7 +2106,7 @@ func ExampleBucket_Put() {
defer os.Remove(db.Path())
// Start a write transaction.
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
// Create a bucket.
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
@@ -2154,7 +2154,7 @@ func ExampleBucket_Delete() {
defer os.Remove(db.Path())
// Start a write transaction.
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
// Create a bucket.
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
@@ -2178,7 +2178,7 @@ func ExampleBucket_Delete() {
}
// Delete the key in a different write transaction.
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
return tx.Bucket([]byte("widgets")).Delete([]byte("foo"))
})
if err != nil {
@@ -2217,7 +2217,7 @@ func ExampleBucket_ForEach() {
defer os.Remove(db.Path())
// Insert data into a bucket.
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("animals"))
if err != nil {
return err
@@ -2271,7 +2271,7 @@ func TestCursor_Seek(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -2361,7 +2361,7 @@ func TestCursor_Delete(t *testing.T) {
const count = 1000
// Insert every other key between 0 and $count.
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -2387,7 +2387,7 @@ func TestCursor_Delete(t *testing.T) {
t.Fatal(err)
}
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
c := tx.Bucket([]byte("widgets")).Cursor()
bound := make([]byte, 8)
binary.BigEndian.PutUint64(bound, uint64(count/2))
@@ -2427,7 +2427,7 @@ func TestCursor_Seek_Large(t *testing.T) {
const count = 10000
// Insert every other key between 0 and $count.
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -2493,7 +2493,7 @@ func TestCursor_EmptyBucket(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
return err
})
@@ -2523,7 +2523,7 @@ func TestCursor_EmptyBucketReverse(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
return err
})
@@ -2553,7 +2553,7 @@ func TestCursor_Iterate_Leaf(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -2636,7 +2636,7 @@ func TestCursor_LeafRootReverse(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -2716,7 +2716,7 @@ func TestCursor_Restart(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -2777,7 +2777,7 @@ func TestCursor_First_EmptyPages(t *testing.T) {
defer os.Remove(db.Path())
// Create 1000 keys in the "widgets" bucket.
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -2797,7 +2797,7 @@ func TestCursor_First_EmptyPages(t *testing.T) {
}
// Delete half the keys and then try to iterate.
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
b := tx.Bucket([]byte("widgets"))
for i := 0; i < 600; i++ {
err := b.Delete(u64tob(uint64(i)))
@@ -2976,7 +2976,7 @@ func TestCursor_QuickCheck_BucketsOnly(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -3030,7 +3030,7 @@ func TestCursor_QuickCheck_BucketsOnly_Reverse(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -3087,7 +3087,7 @@ func ExampleCursor() {
defer os.Remove(db.Path())
// Start a read-write transaction.
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
// Create a new bucket.
b, err := tx.CreateBucket([]byte("animals"))
if err != nil {
@@ -3149,7 +3149,7 @@ func ExampleCursor_reverse() {
defer os.Remove(db.Path())
// Start a read-write transaction.
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
// Create a new bucket.
b, err := tx.CreateBucket([]byte("animals"))
if err != nil {
@@ -3339,7 +3339,7 @@ func TestOpen_Size(t *testing.T) {
pagesize := db.pageSize
// Insert until we get above the minimum 4MB size.
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, _ := tx.CreateBucketIfNotExists([]byte("data"))
for i := 0; i < 10000; i++ {
err := b.Put([]byte(
@@ -3373,7 +3373,7 @@ func TestOpen_Size(t *testing.T) {
t.Fatal(err)
}
- err = db0.Update(func(tx TxI) error {
+ err = db0.Update(func(tx TransactionI) error {
err := tx.Bucket([]byte("data")).Put([]byte{0}, []byte{0})
if err != nil {
t.Fatal(err)
@@ -3424,7 +3424,7 @@ func TestOpen_Size_Large(t *testing.T) {
// Insert until we get above the minimum 4MB size.
var index uint64
for i := 0; i < n1; i++ {
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, _ := tx.CreateBucketIfNotExists([]byte("data"))
for j := 0; j < n2; j++ {
err := b.Put(u64tob(index), make([]byte, 50))
@@ -3460,7 +3460,7 @@ func TestOpen_Size_Large(t *testing.T) {
t.Fatal(err)
}
- err = db0.Update(func(tx TxI) error {
+ err = db0.Update(func(tx TransactionI) error {
return tx.Bucket([]byte("data")).Put([]byte{0}, []byte{0})
})
if err != nil {
@@ -3730,7 +3730,7 @@ func TestDB_Update(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -3779,7 +3779,7 @@ func TestDB_Update(t *testing.T) {
// Ensure a closed database returns an error while running a transaction block
func TestDB_Update_Closed(t *testing.T) {
var db DB
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -3807,7 +3807,7 @@ func TestDB_Update_Panic(t *testing.T) {
}
}()
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -3821,7 +3821,7 @@ func TestDB_Update_Panic(t *testing.T) {
}()
// Verify we can update again.
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -3834,7 +3834,7 @@ func TestDB_Update_Panic(t *testing.T) {
}
// Verify that our change persisted.
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
if tx.Bucket([]byte("widgets")) == nil {
t.Fatal("expected bucket")
}
@@ -3866,7 +3866,7 @@ func TestDB_View_Panic(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -3916,7 +3916,7 @@ func TestDB_Consistency(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
return err
})
@@ -3925,7 +3925,7 @@ func TestDB_Consistency(t *testing.T) {
}
for i := 0; i < 10; i++ {
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
err := tx.Bucket([]byte("widgets")).Put(
[]byte("foo"),
[]byte("bar"),
@@ -3941,7 +3941,7 @@ func TestDB_Consistency(t *testing.T) {
}
}
- err = db.Update(func(itx TxI) error {
+ err = db.Update(func(itx TransactionI) error {
tx := itx.(*Tx)
p, _ := tx.pageInfo(0)
if p == nil {
@@ -4003,7 +4003,7 @@ func TestDB_Batch(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -4020,7 +4020,7 @@ func TestDB_Batch(t *testing.T) {
ch := make(chan error)
for i := 0; i < n; i++ {
go func(i int) {
- ch <- db.Batch(func(tx TxI) error {
+ ch <- db.Batch(func(tx TransactionI) error {
return tx.Bucket([]byte("widgets")).Put(
u64tob(uint64(i)),
[]byte{},
@@ -4073,7 +4073,7 @@ func TestDB_Batch_Panic(t *testing.T) {
problem = p
}
}()
- err = db.Batch(func(tx TxI) error {
+ err = db.Batch(func(tx TransactionI) error {
panic(bork)
})
}()
@@ -4095,7 +4095,7 @@ func TestDB_BatchFull(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
return err
})
@@ -4107,7 +4107,7 @@ func TestDB_BatchFull(t *testing.T) {
// buffered so we never leak goroutines
ch := make(chan error, size)
put := func(i int) {
- ch <- db.Batch(func(tx TxI) error {
+ ch <- db.Batch(func(tx TransactionI) error {
return tx.Bucket([]byte("widgets")).Put(
u64tob(uint64(i)),
[]byte{},
@@ -4164,7 +4164,7 @@ func TestDB_BatchTime(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
return err
})
@@ -4176,7 +4176,7 @@ func TestDB_BatchTime(t *testing.T) {
// buffered so we never leak goroutines
ch := make(chan error, size)
put := func(i int) {
- ch <- db.Batch(func(tx TxI) error {
+ ch <- db.Batch(func(tx TransactionI) error {
return tx.Bucket([]byte("widgets")).Put(
u64tob(uint64(i)),
[]byte{},
@@ -4222,7 +4222,7 @@ func ExampleDB_Update() {
defer os.Remove(db.Path())
// Execute several commands within a read-write transaction.
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
return err
@@ -4268,7 +4268,7 @@ func ExampleDB_View() {
defer os.Remove(db.Path())
// Insert data into a bucket.
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("people"))
if err != nil {
return err
@@ -4320,7 +4320,7 @@ func ExampleDB_Begin_ReadOnly() {
defer os.Remove(db.Path())
// Create a bucket using a read-write transaction.
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
return err
})
@@ -4386,7 +4386,7 @@ func BenchmarkDBBatchAutomatic(b *testing.B) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("bench"))
return err
})
@@ -4411,7 +4411,7 @@ func BenchmarkDBBatchAutomatic(b *testing.B) {
binary.LittleEndian.PutUint32(buf, id)
_, _ = h.Write(buf[:])
k := h.Sum(nil)
- insert := func(tx TxI) error {
+ insert := func(tx TransactionI) error {
b := tx.Bucket([]byte("bench"))
return b.Put(k, []byte("filler"))
}
@@ -4436,7 +4436,7 @@ func BenchmarkDBBatchSingle(b *testing.B) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("bench"))
return err
})
@@ -4460,7 +4460,7 @@ func BenchmarkDBBatchSingle(b *testing.B) {
binary.LittleEndian.PutUint32(buf, id)
_, _ = h.Write(buf[:])
k := h.Sum(nil)
- insert := func(tx TxI) error {
+ insert := func(tx TransactionI) error {
b := tx.Bucket([]byte("bench"))
return b.Put(k, []byte("filler"))
}
@@ -4485,7 +4485,7 @@ func BenchmarkDBBatchManual10x100(b *testing.B) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("bench"))
return err
})
@@ -4504,7 +4504,7 @@ func BenchmarkDBBatchManual10x100(b *testing.B) {
defer wg.Done()
<-start
- insert100 := func(tx TxI) error {
+ insert100 := func(tx TransactionI) error {
h := fnv.New32a()
buf := make([]byte, 4)
for minor := 0; minor < 100; minor++ {
@@ -4544,7 +4544,7 @@ func BenchmarkDBBatchManual10x100(b *testing.B) {
func validateBatchBench(b *testing.B, db *WDB) {
rollback := errors.New("sentinel error to cause rollback")
- validate := func(tx TxI) error {
+ validate := func(tx TransactionI) error {
bucket := tx.Bucket([]byte("bench"))
h := fnv.New32a()
buf := make([]byte, 4)
@@ -4629,7 +4629,7 @@ func (db *WDB) MustClose() {
// MustCheck runs a consistency check on the database and panics if any errors
// are found.
func (db *WDB) MustCheck() {
- err := db.Update(func(itx TxI) error {
+ err := db.Update(func(itx TransactionI) error {
tx := itx.(*Tx)
// Collect all the errors.
errors := []error{}
@@ -5866,7 +5866,7 @@ func TestTx_Cursor(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -5954,7 +5954,7 @@ func TestTx_Bucket(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -5977,7 +5977,7 @@ func TestTx_Get_NotFound(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -6006,7 +6006,7 @@ func TestTx_CreateBucket(t *testing.T) {
defer os.Remove(db.Path())
// Create a bucket.
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -6039,7 +6039,7 @@ func TestTx_CreateBucketIfNotExists(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
// Create bucket.
b, err := tx.CreateBucketIfNotExists([]byte("widgets"))
if err != nil {
@@ -6081,7 +6081,7 @@ func TestTx_CreateBucketIfNotExists_ErrBucketNameRequired(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucketIfNotExists([]byte{})
if err != ErrBucketNameRequired {
t.Fatalf("unexpected error: %s", err)
@@ -6106,7 +6106,7 @@ func TestTx_CreateBucket_ErrBucketExists(t *testing.T) {
defer os.Remove(db.Path())
// Create a bucket.
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -6119,7 +6119,7 @@ func TestTx_CreateBucket_ErrBucketExists(t *testing.T) {
}
// Create the same bucket again.
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
if err != ErrBucketExists {
t.Fatalf("unexpected error: %s", err)
@@ -6138,7 +6138,7 @@ func TestTx_CreateBucket_ErrBucketNameRequired(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket(nil)
if err != ErrBucketNameRequired {
t.Fatalf("unexpected error: %s", err)
@@ -6158,7 +6158,7 @@ func TestTx_DeleteBucket(t *testing.T) {
defer os.Remove(db.Path())
// Create a bucket and add a value.
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -6176,7 +6176,7 @@ func TestTx_DeleteBucket(t *testing.T) {
}
// Delete the bucket and make sure we can't get the value.
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
err := tx.DeleteBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -6192,7 +6192,7 @@ func TestTx_DeleteBucket(t *testing.T) {
t.Fatal(err)
}
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
// Create the bucket again and make sure there's not a phantom
// value.
b, err := tx.CreateBucket([]byte("widgets"))
@@ -6260,7 +6260,7 @@ func TestTx_DeleteBucket_NotFound(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
err := tx.DeleteBucket([]byte("widgets"))
if err != ErrBucketNotFound {
t.Fatalf("unexpected error: %s", err)
@@ -6280,7 +6280,7 @@ func TestTx_ForEach_NoError(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -6311,7 +6311,7 @@ func TestTx_ForEach_WithError(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -6345,7 +6345,7 @@ func TestTx_OnCommit(t *testing.T) {
defer os.Remove(db.Path())
var x int
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
tx.OnCommit(func() { x += 1 })
tx.OnCommit(func() { x += 2 })
_, err := tx.CreateBucket([]byte("widgets"))
@@ -6368,7 +6368,7 @@ func TestTx_OnCommit_Rollback(t *testing.T) {
defer os.Remove(db.Path())
var x int
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
tx.OnCommit(func() { x += 1 })
tx.OnCommit(func() { x += 2 })
_, err := tx.CreateBucket([]byte("widgets"))
@@ -6412,7 +6412,7 @@ func TestTx_WriteTo_Error_Meta(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -6450,7 +6450,7 @@ func TestTx_WriteTo_Error_Normal(t *testing.T) {
defer db.MustClose()
defer os.Remove(db.Path())
- err := db.Update(func(tx TxI) error {
+ err := db.Update(func(tx TransactionI) error {
b, err := tx.CreateBucket([]byte("widgets"))
if err != nil {
t.Fatal(err)
@@ -6491,7 +6491,7 @@ func ExampleTx_Rollback() {
defer os.Remove(db.Path())
// Create a bucket.
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
_, err := tx.CreateBucket([]byte("widgets"))
return err
})
@@ -6500,7 +6500,7 @@ func ExampleTx_Rollback() {
}
// Set a value for a key.
- err = db.Update(func(tx TxI) error {
+ err = db.Update(func(tx TransactionI) error {
return tx.Bucket([]byte("widgets")).Put(
[]byte("foo"),
[]byte("bar"),
generated by cgit v1.2.3 (git 2.49.0) at 2025-07-13 20:30:27 +0000