From b3d1c0fcec182d047233627cd0f0fecab1afce4e Mon Sep 17 00:00:00 2001
From: jay tseng <jay.tseng@crypto.com>
Date: Mon, 12 Sep 2022 18:20:16 -0400
Subject: [PATCH 1/8] add NewDBwithOptions method

---
 backend_test.go |  2 +-
 cleveldb.go     |  2 +-
 db.go           | 14 ++++++++++++--
 goleveldb.go    |  2 +-
 memdb.go        |  2 +-
 pebble.go       |  2 +-
 rocksdb.go      |  2 +-
 7 files changed, 18 insertions(+), 8 deletions(-)

diff --git a/backend_test.go b/backend_test.go
index 258727d..b84bc41 100644
--- a/backend_test.go
+++ b/backend_test.go
@@ -12,7 +12,7 @@ import (
 
 // Register a test backend for PrefixDB as well, with some unrelated junk data
 func init() {
-	registerDBCreator("prefixdb", func(name, dir string) (DB, error) {
+	registerDBCreator("prefixdb", func(name, dir string, opts DBOptions) (DB, error) {
 		mdb := NewMemDB()
 		mdb.Set([]byte("a"), []byte{1})    //nolint:errcheck
 		mdb.Set([]byte("b"), []byte{2})    //nolint:errcheck
diff --git a/cleveldb.go b/cleveldb.go
index a4b467a..d73cd8b 100644
--- a/cleveldb.go
+++ b/cleveldb.go
@@ -11,7 +11,7 @@ import (
 )
 
 func init() {
-	dbCreator := func(name string, dir string) (DB, error) {
+	dbCreator := func(name string, dir string, opts DBOptions) (DB, error) {
 		return NewCLevelDB(name, dir)
 	}
 	registerDBCreator(CLevelDBBackend, dbCreator, false)
diff --git a/db.go b/db.go
index 88f3e69..f183317 100644
--- a/db.go
+++ b/db.go
@@ -31,7 +31,13 @@ const (
 	PebbleDBBackend BackendType = "pebbledb"
 )
 
-type dbCreator func(name string, dir string) (DB, error)
+type (
+	dbCreator func(name string, dir string, opts DBOptions) (DB, error)
+
+	DBOptions interface {
+		Get(string) interface{}
+	}
+)
 
 var backends = map[BackendType]dbCreator{}
 
@@ -45,6 +51,10 @@ func registerDBCreator(backend BackendType, creator dbCreator, force bool) {
 
 // NewDB creates a new database of type backend with the given name.
 func NewDB(name string, backend BackendType, dir string) (DB, error) {
+	return NewDBwithOptions(name, backend, dir, nil)
+}
+
+func NewDBwithOptions(name string, backend BackendType, dir string, opts DBOptions) (DB, error) {
 	dbCreator, ok := backends[backend]
 	if !ok {
 		keys := make([]string, 0, len(backends))
@@ -55,7 +65,7 @@ func NewDB(name string, backend BackendType, dir string) (DB, error) {
 			backend, strings.Join(keys, ","))
 	}
 
-	db, err := dbCreator(name, dir)
+	db, err := dbCreator(name, dir, opts)
 	if err != nil {
 		return nil, fmt.Errorf("failed to initialize database: %w", err)
 	}
diff --git a/goleveldb.go b/goleveldb.go
index 8dd3c3c..9916fd3 100644
--- a/goleveldb.go
+++ b/goleveldb.go
@@ -11,7 +11,7 @@ import (
 )
 
 func init() {
-	dbCreator := func(name string, dir string) (DB, error) {
+	dbCreator := func(name string, dir string, opts DBOptions) (DB, error) {
 		return NewGoLevelDB(name, dir)
 	}
 	registerDBCreator(GoLevelDBBackend, dbCreator, false)
diff --git a/memdb.go b/memdb.go
index feb1664..1780d29 100644
--- a/memdb.go
+++ b/memdb.go
@@ -14,7 +14,7 @@ const (
 )
 
 func init() {
-	registerDBCreator(MemDBBackend, func(name, dir string) (DB, error) {
+	registerDBCreator(MemDBBackend, func(name, dir string, opts DBOptions) (DB, error) {
 		return NewMemDB(), nil
 	}, false)
 }
diff --git a/pebble.go b/pebble.go
index 3be8aa7..a47827c 100644
--- a/pebble.go
+++ b/pebble.go
@@ -54,7 +54,7 @@ var (
 )
 
 func init() {
-	dbCreator := func(name string, dir string) (DB, error) {
+	dbCreator := func(name string, dir string, opts DBOptions) (DB, error) {
 		return NewPebbleDB(name, dir)
 	}
 	registerDBCreator(PebbleDBBackend, dbCreator, false)
diff --git a/rocksdb.go b/rocksdb.go
index 05bdf17..e8ca82c 100644
--- a/rocksdb.go
+++ b/rocksdb.go
@@ -12,7 +12,7 @@ import (
 )
 
 func init() {
-	dbCreator := func(name string, dir string) (DB, error) {
+	dbCreator := func(name string, dir string, opts DBOptions) (DB, error) {
 		return NewRocksDB(name, dir)
 	}
 	registerDBCreator(RocksDBBackend, dbCreator, false)

From b4a832e9bad9abdeb7a7ec444e792210870d1846 Mon Sep 17 00:00:00 2001
From: jay tseng <jay.tseng@crypto.com>
Date: Tue, 13 Sep 2022 13:21:01 -0400
Subject: [PATCH 2/8] implement dboptions in the rocksdb constructor

---
 go.mod     |  3 ++-
 go.sum     |  1 +
 rocksdb.go | 38 ++++++++++++++++++++++++++------------
 3 files changed, 29 insertions(+), 13 deletions(-)

diff --git a/go.mod b/go.mod
index f54feb4..ec8e21d 100644
--- a/go.mod
+++ b/go.mod
@@ -1,12 +1,13 @@
 module github.com/cosmos/cosmos-db
 
-go 1.19
+go 1.18
 
 require (
 	github.com/cockroachdb/pebble v0.0.0-20220817183557-09c6e030a677
 	github.com/google/btree v1.1.2
 	github.com/jmhodges/levigo v1.0.0
 	github.com/linxGnu/grocksdb v1.7.5
+	github.com/spf13/cast v1.3.0
 	github.com/stretchr/testify v1.8.0
 	github.com/syndtr/goleveldb v1.0.1-0.20200815110645-5c35d600f0ca
 )
diff --git a/go.sum b/go.sum
index b2b7a24..f3a9d0b 100644
--- a/go.sum
+++ b/go.sum
@@ -200,6 +200,7 @@ github.com/shurcooL/sanitized_anchor_name v1.0.0/go.mod h1:1NzhyTcUVG4SuEtjjoZeV
 github.com/smartystreets/assertions v0.0.0-20180927180507-b2de0cb4f26d/go.mod h1:OnSkiWE9lh6wB0YB77sQom3nweQdgAjqCqsofrRNTgc=
 github.com/smartystreets/goconvey v1.6.4/go.mod h1:syvi0/a8iFYH4r/RixwvyeAJjdLS9QV7WQ/tjFTllLA=
 github.com/spf13/afero v1.1.2/go.mod h1:j4pytiNVoe2o6bmDsKpLACNPDBIoEAkihy7loJ1B0CQ=
+github.com/spf13/cast v1.3.0 h1:oget//CVOEoFewqQxwr0Ej5yjygnqGkvggSE/gB35Q8=
 github.com/spf13/cast v1.3.0/go.mod h1:Qx5cxh0v+4UWYiBimWS+eyWzqEqokIECu5etghLkUJE=
 github.com/spf13/cobra v0.0.5/go.mod h1:3K3wKZymM7VvHMDS9+Akkh4K60UwM26emMESw8tLCHU=
 github.com/spf13/jwalterweatherman v1.0.0/go.mod h1:cQK4TGJAtQXfYWX+Ddv3mKDzgVb68N+wFjFa4jdeBTo=
diff --git a/rocksdb.go b/rocksdb.go
index e8ca82c..712ca8c 100644
--- a/rocksdb.go
+++ b/rocksdb.go
@@ -9,11 +9,12 @@ import (
 	"runtime"
 
 	"github.com/linxGnu/grocksdb"
+	"github.com/spf13/cast"
 )
 
 func init() {
 	dbCreator := func(name string, dir string, opts DBOptions) (DB, error) {
-		return NewRocksDB(name, dir)
+		return NewRocksDB(name, dir, opts)
 	}
 	registerDBCreator(RocksDBBackend, dbCreator, false)
 }
@@ -28,23 +29,36 @@ type RocksDB struct {
 
 var _ DB = (*RocksDB)(nil)
 
-func NewRocksDB(name string, dir string) (*RocksDB, error) {
-	// default rocksdb option, good enough for most cases, including heavy workloads.
-	// 1GB table cache, 512MB write buffer(may use 50% more on heavy workloads).
-	// compression: snappy as default, need to -lsnappy to enable.
+// defaultRocksdbOptions, good enough for most cases, including heavy workloads.
+// 1GB table cache, 512MB write buffer(may use 50% more on heavy workloads).
+// compression: snappy as default, need to -lsnappy to enable.
+func defaultRocksdbOptions() *grocksdb.Options {
 	bbto := grocksdb.NewDefaultBlockBasedTableOptions()
 	bbto.SetBlockCache(grocksdb.NewLRUCache(1 << 30))
 	bbto.SetFilterPolicy(grocksdb.NewBloomFilter(10))
 
-	opts := grocksdb.NewDefaultOptions()
-	opts.SetBlockBasedTableFactory(bbto)
+	rocksdbOpts := grocksdb.NewDefaultOptions()
+	rocksdbOpts.SetBlockBasedTableFactory(bbto)
 	// SetMaxOpenFiles to 4096 seems to provide a reliable performance boost
-	opts.SetMaxOpenFiles(4096)
-	opts.SetCreateIfMissing(true)
-	opts.IncreaseParallelism(runtime.NumCPU())
+	rocksdbOpts.SetMaxOpenFiles(4096)
+	rocksdbOpts.SetCreateIfMissing(true)
+	rocksdbOpts.IncreaseParallelism(runtime.NumCPU())
 	// 1.5GB maximum memory use for writebuffer.
-	opts.OptimizeLevelStyleCompaction(512 * 1024 * 1024)
-	return NewRocksDBWithOptions(name, dir, opts)
+	rocksdbOpts.OptimizeLevelStyleCompaction(512 * 1024 * 1024)
+	return rocksdbOpts
+}
+
+func NewRocksDB(name string, dir string, opts DBOptions) (*RocksDB, error) {
+	defaultOpts := defaultRocksdbOptions()
+
+	if opts != nil {
+		files := cast.ToInt(opts.Get("maxopenfiles"))
+		if files > 0 {
+			defaultOpts.SetMaxOpenFiles(files)
+		}
+	}
+
+	return NewRocksDBWithOptions(name, dir, defaultOpts)
 }
 
 func NewRocksDBWithOptions(name string, dir string, opts *grocksdb.Options) (*RocksDB, error) {

From b902fcec167ff5a230592a6a2b78468b5af58223 Mon Sep 17 00:00:00 2001
From: jay tseng <jay.tseng@crypto.com>
Date: Tue, 13 Sep 2022 13:21:19 -0400
Subject: [PATCH 3/8] add test

---
 rocksdb_test.go | 21 +++++++++++++++++++--
 util.go         | 12 ++++++++++++
 2 files changed, 31 insertions(+), 2 deletions(-)

diff --git a/rocksdb_test.go b/rocksdb_test.go
index bd67934..e8c8530 100644
--- a/rocksdb_test.go
+++ b/rocksdb_test.go
@@ -9,6 +9,7 @@ import (
 	"path/filepath"
 	"testing"
 
+	"github.com/spf13/cast"
 	"github.com/stretchr/testify/assert"
 	"github.com/stretchr/testify/require"
 )
@@ -28,7 +29,7 @@ func TestWithRocksDB(t *testing.T) {
 	dir := t.TempDir()
 	path := filepath.Join(dir, "rocksdb")
 
-	db, err := NewRocksDB(path, "")
+	db, err := NewRocksDB(path, "", nil)
 	require.NoError(t, err)
 
 	t.Run("RocksDB", func(t *testing.T) { Run(t, db) })
@@ -44,4 +45,20 @@ func TestRocksDBStats(t *testing.T) {
 	assert.NotEmpty(t, db.Stats())
 }
 
-// TODO: Add tests for rocksdb
+func TestRocksDBWithOptions(t *testing.T) {
+	dir := t.TempDir()
+	path := filepath.Join(dir, "rocksdb")
+
+	opts := make(DBOptionsMap, 0)
+	opts["maxopenfiles"] = 1000
+
+	defaultOpts := defaultRocksdbOptions()
+	files := cast.ToInt(opts.Get("maxopenfiles"))
+	defaultOpts.SetMaxOpenFiles(files)
+	require.Equal(t, opts["maxopenfiles"], defaultOpts.GetMaxOpenFiles())
+
+	db, err := NewRocksDB(path, "", opts)
+	require.NoError(t, err)
+
+	t.Run("RocksDB", func(t *testing.T) { Run(t, db) })
+}
diff --git a/util.go b/util.go
index da0b635..a639228 100644
--- a/util.go
+++ b/util.go
@@ -49,3 +49,15 @@ func FileExists(filePath string) bool {
 	_, err := os.Stat(filePath)
 	return !os.IsNotExist(err)
 }
+
+// DBOptionsMap is a stub implementing DBOptions which can get data from a map
+type DBOptionsMap map[string]interface{}
+
+func (m DBOptionsMap) Get(key string) interface{} {
+	v, ok := m[key]
+	if !ok {
+		return interface{}(nil)
+	}
+
+	return v
+}

From 16321c56ee68f32926a3c2bd1b1dd621a33e44fc Mon Sep 17 00:00:00 2001
From: jay tseng <jay.tseng@crypto.com>
Date: Tue, 13 Sep 2022 13:46:36 -0400
Subject: [PATCH 4/8] implement dboptions in the goleveldb constructor

---
 goleveldb.go      | 16 +++++++++++++---
 goleveldb_test.go |  6 +++---
 prefixdb_test.go  |  2 +-
 3 files changed, 17 insertions(+), 7 deletions(-)

diff --git a/goleveldb.go b/goleveldb.go
index 9916fd3..23c7005 100644
--- a/goleveldb.go
+++ b/goleveldb.go
@@ -4,6 +4,7 @@ import (
 	"fmt"
 	"path/filepath"
 
+	"github.com/spf13/cast"
 	"github.com/syndtr/goleveldb/leveldb"
 	"github.com/syndtr/goleveldb/leveldb/errors"
 	"github.com/syndtr/goleveldb/leveldb/opt"
@@ -12,7 +13,7 @@ import (
 
 func init() {
 	dbCreator := func(name string, dir string, opts DBOptions) (DB, error) {
-		return NewGoLevelDB(name, dir)
+		return NewGoLevelDB(name, dir, opts)
 	}
 	registerDBCreator(GoLevelDBBackend, dbCreator, false)
 }
@@ -23,8 +24,17 @@ type GoLevelDB struct {
 
 var _ DB = (*GoLevelDB)(nil)
 
-func NewGoLevelDB(name string, dir string) (*GoLevelDB, error) {
-	return NewGoLevelDBWithOpts(name, dir, nil)
+func NewGoLevelDB(name string, dir string, opts DBOptions) (*GoLevelDB, error) {
+	defaultOpts := &opt.Options{}
+
+	if opts != nil {
+		files := cast.ToInt(opts.Get("maxopenfiles"))
+		if files > 0 {
+			defaultOpts.OpenFilesCacheCapacity = files
+		}
+	}
+
+	return NewGoLevelDBWithOpts(name, dir, defaultOpts)
 }
 
 func NewGoLevelDBWithOpts(name string, dir string, o *opt.Options) (*GoLevelDB, error) {
diff --git a/goleveldb_test.go b/goleveldb_test.go
index e1c879f..db9189e 100644
--- a/goleveldb_test.go
+++ b/goleveldb_test.go
@@ -13,9 +13,9 @@ func TestGoLevelDBNewGoLevelDB(t *testing.T) {
 	defer cleanupDBDir("", name)
 
 	// Test we can't open the db twice for writing
-	wr1, err := NewGoLevelDB(name, "")
+	wr1, err := NewGoLevelDB(name, "", nil)
 	require.Nil(t, err)
-	_, err = NewGoLevelDB(name, "")
+	_, err = NewGoLevelDB(name, "", nil)
 	require.NotNil(t, err)
 	wr1.Close() // Close the db to release the lock
 
@@ -30,7 +30,7 @@ func TestGoLevelDBNewGoLevelDB(t *testing.T) {
 
 func BenchmarkGoLevelDBRandomReadsWrites(b *testing.B) {
 	name := fmt.Sprintf("test_%x", randStr(12))
-	db, err := NewGoLevelDB(name, "")
+	db, err := NewGoLevelDB(name, "", nil)
 	if err != nil {
 		b.Fatal(err)
 	}
diff --git a/prefixdb_test.go b/prefixdb_test.go
index e9832c4..7191a31 100644
--- a/prefixdb_test.go
+++ b/prefixdb_test.go
@@ -39,7 +39,7 @@ func randomValue() []byte {
 func TestGolevelDB(t *testing.T) {
 	path := filepath.Join(t.TempDir(), "goleveldb")
 
-	db, err := NewGoLevelDB(path, "")
+	db, err := NewGoLevelDB(path, "", nil)
 	require.NoError(t, err)
 
 	Run(t, db)

From 1d6628840b6d2968ee59159025e93bbd8358d1c6 Mon Sep 17 00:00:00 2001
From: jay tseng <jay.tseng@crypto.com>
Date: Tue, 13 Sep 2022 13:51:54 -0400
Subject: [PATCH 5/8] implement dboptions in the cleveldb constructor

---
 cleveldb.go      | 25 +++++++++++++++++++------
 cleveldb_test.go |  4 ++--
 2 files changed, 21 insertions(+), 8 deletions(-)

diff --git a/cleveldb.go b/cleveldb.go
index d73cd8b..ee25d5e 100644
--- a/cleveldb.go
+++ b/cleveldb.go
@@ -8,11 +8,12 @@ import (
 	"path/filepath"
 
 	"github.com/jmhodges/levigo"
+	"github.com/spf13/cast"
 )
 
 func init() {
 	dbCreator := func(name string, dir string, opts DBOptions) (DB, error) {
-		return NewCLevelDB(name, dir)
+		return NewCLevelDB(name, dir, opts)
 	}
 	registerDBCreator(CLevelDBBackend, dbCreator, false)
 }
@@ -27,14 +28,26 @@ type CLevelDB struct {
 
 var _ DB = (*CLevelDB)(nil)
 
-// NewCLevelDB creates a new CLevelDB.
-func NewCLevelDB(name string, dir string) (*CLevelDB, error) {
-	dbPath := filepath.Join(dir, name+".db")
-
+func defaultCleveldbOptions() *levigo.Options {
 	opts := levigo.NewOptions()
 	opts.SetCache(levigo.NewLRUCache(1 << 30))
 	opts.SetCreateIfMissing(true)
-	db, err := levigo.Open(dbPath, opts)
+	return opts
+}
+
+// NewCLevelDB creates a new CLevelDB.
+func NewCLevelDB(name string, dir string, opts DBOptions) (*CLevelDB, error) {
+	do := defaultCleveldbOptions()
+
+	if opts != nil {
+		files := cast.ToInt(opts.Get("maxopenfiles"))
+		if files > 0 {
+			do.SetMaxOpenFiles(files)
+		}
+	}
+
+	dbPath := filepath.Join(dir, name+".db")
+	db, err := levigo.Open(dbPath, do)
 	if err != nil {
 		return nil, err
 	}
diff --git a/cleveldb_test.go b/cleveldb_test.go
index 2930067..157a165 100644
--- a/cleveldb_test.go
+++ b/cleveldb_test.go
@@ -19,7 +19,7 @@ func TestWithClevelDB(t *testing.T) {
 	dir := t.TempDir()
 	path := filepath.Join(dir, "cleveldb")
 
-	db, err := NewCLevelDB(path, "")
+	db, err := NewCLevelDB(path, "", nil)
 	require.NoError(t, err)
 
 	t.Run("ClevelDB", func(t *testing.T) { Run(t, db) })
@@ -33,7 +33,7 @@ func BenchmarkRandomReadsWrites2(b *testing.B) {
 	for i := 0; i < int(numItems); i++ {
 		internal[int64(i)] = int64(0)
 	}
-	db, err := NewCLevelDB(fmt.Sprintf("test_%x", randStr(12)), "")
+	db, err := NewCLevelDB(fmt.Sprintf("test_%x", randStr(12)), "", nil)
 	if err != nil {
 		b.Fatal(err.Error())
 		return

From 025a9aa97e2bcf5c11d17a2cab94cd15272c14f5 Mon Sep 17 00:00:00 2001
From: jay tseng <jay.tseng@crypto.com>
Date: Tue, 13 Sep 2022 13:57:32 -0400
Subject: [PATCH 6/8] implement dboptions in the pebbledb constructor

---
 pebble.go | 20 ++++++++++++++------
 1 file changed, 14 insertions(+), 6 deletions(-)

diff --git a/pebble.go b/pebble.go
index a47827c..6b0d9ee 100644
--- a/pebble.go
+++ b/pebble.go
@@ -8,6 +8,7 @@ import (
 	"path/filepath"
 
 	"github.com/cockroachdb/pebble"
+	"github.com/spf13/cast"
 )
 
 // ForceSync
@@ -55,7 +56,7 @@ var (
 
 func init() {
 	dbCreator := func(name string, dir string, opts DBOptions) (DB, error) {
-		return NewPebbleDB(name, dir)
+		return NewPebbleDB(name, dir, opts)
 	}
 	registerDBCreator(PebbleDBBackend, dbCreator, false)
 
@@ -71,15 +72,22 @@ type PebbleDB struct {
 
 var _ DB = (*PebbleDB)(nil)
 
-func NewPebbleDB(name string, dir string) (DB, error) {
-	dbPath := filepath.Join(dir, name+".db")
-	opts := &pebble.Options{
+func NewPebbleDB(name string, dir string, opts DBOptions) (DB, error) {
+	do := &pebble.Options{
 		MaxConcurrentCompactions: func() int { return 3 }, // default 1
 	}
 
-	opts.EnsureDefaults()
+	do.EnsureDefaults()
 
-	p, err := pebble.Open(dbPath, opts)
+	if opts != nil {
+		files := cast.ToInt(opts.Get("maxopenfiles"))
+		if files > 0 {
+			do.MaxOpenFiles = files
+		}
+	}
+
+	dbPath := filepath.Join(dir, name+".db")
+	p, err := pebble.Open(dbPath, do)
 	if err != nil {
 		return nil, err
 	}

From 979347e5ba272fbc1e439468aff253a3947543ee Mon Sep 17 00:00:00 2001
From: jay tseng <jay.tseng@crypto.com>
Date: Tue, 13 Sep 2022 14:03:17 -0400
Subject: [PATCH 7/8] fix go version

---
 go.mod | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/go.mod b/go.mod
index ec8e21d..0f144b6 100644
--- a/go.mod
+++ b/go.mod
@@ -1,6 +1,6 @@
 module github.com/cosmos/cosmos-db
 
-go 1.18
+go 1.19
 
 require (
 	github.com/cockroachdb/pebble v0.0.0-20220817183557-09c6e030a677

From 4f26414381936d8a05cacf98c1a3f16846480675 Mon Sep 17 00:00:00 2001
From: jay tseng <jay.tseng@crypto.com>
Date: Wed, 14 Sep 2022 12:08:47 -0400
Subject: [PATCH 8/8] fix lint

---
 backend_test.go | 2 +-
 cleveldb.go     | 4 ++--
 db.go           | 6 +++---
 goleveldb.go    | 4 ++--
 memdb.go        | 2 +-
 pebble.go       | 4 ++--
 rocksdb.go      | 4 ++--
 rocksdb_test.go | 2 +-
 util.go         | 6 +++---
 9 files changed, 17 insertions(+), 17 deletions(-)

diff --git a/backend_test.go b/backend_test.go
index b84bc41..8a66817 100644
--- a/backend_test.go
+++ b/backend_test.go
@@ -12,7 +12,7 @@ import (
 
 // Register a test backend for PrefixDB as well, with some unrelated junk data
 func init() {
-	registerDBCreator("prefixdb", func(name, dir string, opts DBOptions) (DB, error) {
+	registerDBCreator("prefixdb", func(name, dir string, opts Options) (DB, error) {
 		mdb := NewMemDB()
 		mdb.Set([]byte("a"), []byte{1})    //nolint:errcheck
 		mdb.Set([]byte("b"), []byte{2})    //nolint:errcheck
diff --git a/cleveldb.go b/cleveldb.go
index ee25d5e..4351a72 100644
--- a/cleveldb.go
+++ b/cleveldb.go
@@ -12,7 +12,7 @@ import (
 )
 
 func init() {
-	dbCreator := func(name string, dir string, opts DBOptions) (DB, error) {
+	dbCreator := func(name string, dir string, opts Options) (DB, error) {
 		return NewCLevelDB(name, dir, opts)
 	}
 	registerDBCreator(CLevelDBBackend, dbCreator, false)
@@ -36,7 +36,7 @@ func defaultCleveldbOptions() *levigo.Options {
 }
 
 // NewCLevelDB creates a new CLevelDB.
-func NewCLevelDB(name string, dir string, opts DBOptions) (*CLevelDB, error) {
+func NewCLevelDB(name string, dir string, opts Options) (*CLevelDB, error) {
 	do := defaultCleveldbOptions()
 
 	if opts != nil {
diff --git a/db.go b/db.go
index f183317..be4da04 100644
--- a/db.go
+++ b/db.go
@@ -32,9 +32,9 @@ const (
 )
 
 type (
-	dbCreator func(name string, dir string, opts DBOptions) (DB, error)
+	dbCreator func(name string, dir string, opts Options) (DB, error)
 
-	DBOptions interface {
+	Options interface {
 		Get(string) interface{}
 	}
 )
@@ -54,7 +54,7 @@ func NewDB(name string, backend BackendType, dir string) (DB, error) {
 	return NewDBwithOptions(name, backend, dir, nil)
 }
 
-func NewDBwithOptions(name string, backend BackendType, dir string, opts DBOptions) (DB, error) {
+func NewDBwithOptions(name string, backend BackendType, dir string, opts Options) (DB, error) {
 	dbCreator, ok := backends[backend]
 	if !ok {
 		keys := make([]string, 0, len(backends))
diff --git a/goleveldb.go b/goleveldb.go
index 23c7005..372ae56 100644
--- a/goleveldb.go
+++ b/goleveldb.go
@@ -12,7 +12,7 @@ import (
 )
 
 func init() {
-	dbCreator := func(name string, dir string, opts DBOptions) (DB, error) {
+	dbCreator := func(name string, dir string, opts Options) (DB, error) {
 		return NewGoLevelDB(name, dir, opts)
 	}
 	registerDBCreator(GoLevelDBBackend, dbCreator, false)
@@ -24,7 +24,7 @@ type GoLevelDB struct {
 
 var _ DB = (*GoLevelDB)(nil)
 
-func NewGoLevelDB(name string, dir string, opts DBOptions) (*GoLevelDB, error) {
+func NewGoLevelDB(name string, dir string, opts Options) (*GoLevelDB, error) {
 	defaultOpts := &opt.Options{}
 
 	if opts != nil {
diff --git a/memdb.go b/memdb.go
index 1780d29..5861811 100644
--- a/memdb.go
+++ b/memdb.go
@@ -14,7 +14,7 @@ const (
 )
 
 func init() {
-	registerDBCreator(MemDBBackend, func(name, dir string, opts DBOptions) (DB, error) {
+	registerDBCreator(MemDBBackend, func(name, dir string, opts Options) (DB, error) {
 		return NewMemDB(), nil
 	}, false)
 }
diff --git a/pebble.go b/pebble.go
index 6b0d9ee..8c1f1bb 100644
--- a/pebble.go
+++ b/pebble.go
@@ -55,7 +55,7 @@ var (
 )
 
 func init() {
-	dbCreator := func(name string, dir string, opts DBOptions) (DB, error) {
+	dbCreator := func(name string, dir string, opts Options) (DB, error) {
 		return NewPebbleDB(name, dir, opts)
 	}
 	registerDBCreator(PebbleDBBackend, dbCreator, false)
@@ -72,7 +72,7 @@ type PebbleDB struct {
 
 var _ DB = (*PebbleDB)(nil)
 
-func NewPebbleDB(name string, dir string, opts DBOptions) (DB, error) {
+func NewPebbleDB(name string, dir string, opts Options) (DB, error) {
 	do := &pebble.Options{
 		MaxConcurrentCompactions: func() int { return 3 }, // default 1
 	}
diff --git a/rocksdb.go b/rocksdb.go
index 712ca8c..cfa2e90 100644
--- a/rocksdb.go
+++ b/rocksdb.go
@@ -13,7 +13,7 @@ import (
 )
 
 func init() {
-	dbCreator := func(name string, dir string, opts DBOptions) (DB, error) {
+	dbCreator := func(name string, dir string, opts Options) (DB, error) {
 		return NewRocksDB(name, dir, opts)
 	}
 	registerDBCreator(RocksDBBackend, dbCreator, false)
@@ -48,7 +48,7 @@ func defaultRocksdbOptions() *grocksdb.Options {
 	return rocksdbOpts
 }
 
-func NewRocksDB(name string, dir string, opts DBOptions) (*RocksDB, error) {
+func NewRocksDB(name string, dir string, opts Options) (*RocksDB, error) {
 	defaultOpts := defaultRocksdbOptions()
 
 	if opts != nil {
diff --git a/rocksdb_test.go b/rocksdb_test.go
index e8c8530..b176fe8 100644
--- a/rocksdb_test.go
+++ b/rocksdb_test.go
@@ -49,7 +49,7 @@ func TestRocksDBWithOptions(t *testing.T) {
 	dir := t.TempDir()
 	path := filepath.Join(dir, "rocksdb")
 
-	opts := make(DBOptionsMap, 0)
+	opts := make(OptionsMap, 0)
 	opts["maxopenfiles"] = 1000
 
 	defaultOpts := defaultRocksdbOptions()
diff --git a/util.go b/util.go
index a639228..da2b005 100644
--- a/util.go
+++ b/util.go
@@ -50,10 +50,10 @@ func FileExists(filePath string) bool {
 	return !os.IsNotExist(err)
 }
 
-// DBOptionsMap is a stub implementing DBOptions which can get data from a map
-type DBOptionsMap map[string]interface{}
+// OptionsMap is a stub implementing Options which can get data from a map
+type OptionsMap map[string]interface{}
 
-func (m DBOptionsMap) Get(key string) interface{} {
+func (m OptionsMap) Get(key string) interface{} {
 	v, ok := m[key]
 	if !ok {
 		return interface{}(nil)