aboutsummaryrefslogtreecommitdiff
path: root/bucket_test.go
diff options
context:
space:
mode:
authorBen Johnson <benbjohnson@yahoo.com>2014-06-22 10:00:04 -0600
committerBen Johnson <benbjohnson@yahoo.com>2014-06-22 10:00:04 -0600
commit622c1f1525b1146c57a10915ef364d1de2e4c803 (patch)
tree270e042d5a039cceb56fd871c93bf4aa3cde75de /bucket_test.go
parentMerge pull request #206 from Shopify/pending_page_stats (diff)
parentChange Bucket.NextSequence() to return uint64. (diff)
downloaddedo-622c1f1525b1146c57a10915ef364d1de2e4c803.tar.gz
dedo-622c1f1525b1146c57a10915ef364d1de2e4c803.tar.xz
Merge pull request #209 from benbjohnson/next-seq-uint64
Change Bucket.NextSequence() to return uint64
Diffstat (limited to 'bucket_test.go')
-rw-r--r--bucket_test.go26
1 files changed, 4 insertions, 22 deletions
diff --git a/bucket_test.go b/bucket_test.go
index 5a1b81c..fbaaeb6 100644
--- a/bucket_test.go
+++ b/bucket_test.go
@@ -451,15 +451,15 @@ func TestBucket_NextSequence(t *testing.T) {
// Make sure sequence increments.
seq, err := tx.Bucket([]byte("widgets")).NextSequence()
assert.NoError(t, err)
- assert.Equal(t, seq, 1)
+ assert.Equal(t, seq, uint64(1))
seq, err = tx.Bucket([]byte("widgets")).NextSequence()
assert.NoError(t, err)
- assert.Equal(t, seq, 2)
+ assert.Equal(t, seq, uint64(2))
// Buckets should be separate.
seq, err = tx.Bucket([]byte("woojits")).NextSequence()
assert.NoError(t, err)
- assert.Equal(t, seq, 1)
+ assert.Equal(t, seq, uint64(1))
return nil
})
})
@@ -475,31 +475,13 @@ func TestBucket_NextSequence_ReadOnly(t *testing.T) {
db.View(func(tx *Tx) error {
b := tx.Bucket([]byte("widgets"))
i, err := b.NextSequence()
- assert.Equal(t, i, 0)
+ assert.Equal(t, i, uint64(0))
assert.Equal(t, err, ErrTxNotWritable)
return nil
})
})
}
-// Ensure that incrementing past the maximum sequence number will return an error.
-func TestBucket_NextSequence_Overflow(t *testing.T) {
- withOpenDB(func(db *DB, path string) {
- db.Update(func(tx *Tx) error {
- tx.CreateBucket([]byte("widgets"))
- return nil
- })
- db.Update(func(tx *Tx) error {
- b := tx.Bucket([]byte("widgets"))
- b.bucket.sequence = uint64(maxInt)
- seq, err := b.NextSequence()
- assert.Equal(t, err, ErrSequenceOverflow)
- assert.Equal(t, seq, 0)
- return nil
- })
- })
-}
-
// Ensure that retrieving the next sequence for a bucket on a closed database return an error.
func TestBucket_NextSequence_Closed(t *testing.T) {
withOpenDB(func(db *DB, path string) {