diff options
author | EuAndreh <eu@euandre.org> | 2025-01-25 14:23:53 -0300 |
---|---|---|
committer | EuAndreh <eu@euandre.org> | 2025-01-25 14:23:53 -0300 |
commit | 283a334dd85e71f45071b9b66cfa0d76ad99d6d2 (patch) | |
tree | 9f7ccd30c356c316e8b99d5a46648e38ab40d99e | |
parent | src/dedo.go: Remove Bucket.Writable() and Tx.Writable() public API (diff) | |
download | dedo-283a334dd85e71f45071b9b66cfa0d76ad99d6d2.tar.gz dedo-283a334dd85e71f45071b9b66cfa0d76ad99d6d2.tar.xz |
src/dedo.go: Remove Bucket.Sequence() and Bucket.SetSequence()
-rw-r--r-- | src/dedo.go | 25 | ||||
-rw-r--r-- | tests/dedo.go | 53 |
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 }, |