aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorEuAndreh <eu@euandre.org>2025-01-25 14:23:53 -0300
committerEuAndreh <eu@euandre.org>2025-01-25 14:23:53 -0300
commit283a334dd85e71f45071b9b66cfa0d76ad99d6d2 (patch)
tree9f7ccd30c356c316e8b99d5a46648e38ab40d99e
parentsrc/dedo.go: Remove Bucket.Writable() and Tx.Writable() public API (diff)
downloaddedo-283a334dd85e71f45071b9b66cfa0d76ad99d6d2.tar.gz
dedo-283a334dd85e71f45071b9b66cfa0d76ad99d6d2.tar.xz
src/dedo.go: Remove Bucket.Sequence() and Bucket.SetSequence()
-rw-r--r--src/dedo.go25
-rw-r--r--tests/dedo.go53
2 files changed, 1 insertions, 77 deletions
diff --git a/src/dedo.go b/src/dedo.go
index 592bd17..12fdad6 100644
--- a/src/dedo.go
+++ b/src/dedo.go
@@ -792,31 +792,6 @@ func (b *Bucket) Delete(key []byte) error {
return nil
}
-/// Bucket.Sequence() returns the current integer for the bucket without
-/// incrementing it.
-func (b *Bucket) Sequence() uint64 {
- return b.ref.sequence
-}
-
-/// Bucket.SetSequence() updates the sequence number for the bucket.
-func (b *Bucket) SetSequence(v uint64) error {
- if b.tx.db == nil {
- return ErrTxClosed
- } else if !b.tx.writable {
- return ErrTxNotWritable
- }
-
- // Materialize the root node if it hasn't been already so that the
- // bucket will be saved during commit.
- if b.rootNode == nil {
- _ = b.node(b.ref.root, nil)
- }
-
- // Increment and return the sequence.
- b.ref.sequence = v
- return nil
-}
-
/// Bucket.NextSequence() returns an autoincrementing integer for the bucket.
func (b *Bucket) NextSequence() (uint64, error) {
if b.tx.db == nil {
diff --git a/tests/dedo.go b/tests/dedo.go
index ddb217d..0506aa2 100644
--- a/tests/dedo.go
+++ b/tests/dedo.go
@@ -1088,56 +1088,6 @@ func TestBucket_DeleteBucket_IncompatibleValue(t *testing.T) {
}
}
-// Ensure bucket can set and update its sequence number.
-func TestBucket_Sequence(t *testing.T) {
- db := MustOpenDB()
- defer db.MustClose()
- defer os.Remove(db.Path())
-
- err := db.Update(func(tx *Tx) error {
- bkt, err := tx.CreateBucket([]byte("0"))
- if err != nil {
- t.Fatal(err)
- }
-
- // Retrieve sequence.
- v := bkt.Sequence()
- if v != 0 {
- t.Fatalf("unexpected sequence: %d", v)
- }
-
- // Update sequence.
- err = bkt.SetSequence(1000)
- if err != nil {
- t.Fatal(err)
- }
-
- // Read sequence again.
- v = bkt.Sequence()
- if v != 1000 {
- t.Fatalf("unexpected sequence: %d", v)
- }
-
- return nil
- })
- if err != nil {
- t.Fatal(err)
- }
-
- // Verify sequence in separate transaction.
- err = db.View(func(tx *Tx) error {
- v := tx.Bucket([]byte("0")).Sequence()
- if v != 1000 {
- t.Fatalf("unexpected sequence: %d", v)
- }
-
- return nil
- })
- if err != nil {
- t.Fatal(err)
- }
-}
-
// Ensure that a bucket can return an autoincrementing sequence.
func TestBucket_NextSequence(t *testing.T) {
db := MustOpenDB()
@@ -6399,7 +6349,7 @@ func fillBucket(b *Bucket, prefix []byte) error {
}
func walkBucket(parent *Bucket, k []byte, v []byte, w io.Writer) error {
- _, err := fmt.Fprintf(w, "%d:%x=%x\n", parent.Sequence(), k, v)
+ _, err := fmt.Fprintf(w, "%d:%x=%x\n", parent.ref.sequence, k, v)
if err != nil {
return err
}
@@ -6453,7 +6403,6 @@ func MainTest() {
{ "TestBucket_Bucket_IncompatibleValue", TestBucket_Bucket_IncompatibleValue },
{ "TestBucket_CreateBucket_IncompatibleValue", TestBucket_CreateBucket_IncompatibleValue },
{ "TestBucket_DeleteBucket_IncompatibleValue", TestBucket_DeleteBucket_IncompatibleValue },
- { "TestBucket_Sequence", TestBucket_Sequence },
{ "TestBucket_NextSequence", TestBucket_NextSequence },
{ "TestBucket_NextSequence_Persist", TestBucket_NextSequence_Persist },
{ "TestBucket_NextSequence_ReadOnly", TestBucket_NextSequence_ReadOnly },