fix(merge): move Merge to db.RunCompaction()

db.go

@@ -761,7 +761,7 @@ func (db *Db) walk(s string, file fs.DirEntry, err error) error {
 
 // Syncs the database. Will remove all expired/deleted keys from disk.
 // Since items are removed, disk usage will reduce.
-func (db *Db) Merge() error {
+func (db *Db) merge() error {
 	defer db.closeActiveMergeDataFilePointer()
 	err := filepath.WalkDir(db.dirPath, db.walk)
 	if err != nil {
@@ -784,3 +784,13 @@ func (db *Db) Merge() error {
 
 	return nil
 }
+
+func (db *Db) RunCompaction() error {
+	// TODO:
+	// 1. Compaction
+	// 2. HintFiles
+	if err := db.merge(); err != nil {
+		return err
+	}
+	return nil
+}

db_test.go

@@ -219,7 +219,7 @@ func Test_Merge(t *testing.T) {
 	filesBeforeMerge, err := filepath.Glob(filepath.Join(opts.Path, "*"))
 	assert.Nil(t, err)
 
-	err = d.Merge()
+	err = d.RunCompaction()
 	assert.Nil(t, err)
 
 	filesAfterMerge, err := filepath.Glob(filepath.Join(opts.Path, "*"))

examples/db/db.go

@@ -84,7 +84,7 @@ func main() {
 			}
 			fmt.Println(string(z))
 		case "merge":
-			d.Merge()
+			d.RunCompaction()
 		case "keyreader":
 			prefix := ""
 			d.KeyReader(prefix, func(k []byte) {