Merge pull request #15 from manosriram/feat/merge

Add Merge feature

Makefile

@@ -9,6 +9,7 @@ build:
 
 clean:
 	rm -rf ./nimbusdb_temp* benchmark/nimbusdb_temp*
+	rm -rf ~/nimbusdb/test_data
 
 test:
 	go test -v -failfast

README.md

@@ -34,7 +34,7 @@ As time passes, expired or deleted keys take up space that is not useful. Hence,
   <summary>
   Supports Merge
   </summary>
-  Supports `Sync` which can be called periodically to remove expired/deleted keys from disk and free-up more space.
+  Supports `Merge` which can be called periodically to remove expired/deleted keys from disk and free-up space.
 </details>
 
 <details>
@@ -103,6 +103,15 @@ if err != nil {
 }
 ```
 
+#### Merge
+
+```go
+err := d.Merge()
+if err != nil {
+  // handle error
+}
+```
+
 #### Batch Operations
 ```go
 d, err := nimbusdb.Open(&nimbusdb.Options{Path: "/path/to/data/directory"})

batch.go

@@ -2,28 +2,12 @@ package nimbusdb
 
 import (
 	"bytes"
-	"errors"
-	"sync"
 	"time"
 
 	"github.com/manosriram/nimbusdb/utils"
 	"github.com/segmentio/ksuid"
 )
 
-var (
-	ERROR_BATCH_CLOSED              = errors.New("batch is closed")
-	ERROR_CANNOT_CLOSE_CLOSED_BATCH = errors.New("cannot close closed batch")
-)
-
-type Batch struct {
-	id         ksuid.KSUID
-	db         *Db
-	closed     bool
-	batchlock  sync.Mutex
-	mu         sync.RWMutex
-	writeQueue []*KeyValuePair
-}
-
 func (db *Db) NewBatch() (*Batch, error) {
 	b := &Batch{
 		db:     db,