Skip to content

Commit 7e3a521

Browse files
set custom badger options
1 parent 8eaec10 commit 7e3a521

File tree

2 files changed

+11
-6
lines changed

2 files changed

+11
-6
lines changed

stakedb/ticketpool.go

Lines changed: 10 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -169,14 +169,21 @@ func dbVersion(db *badger.DB) (uint32, error) {
169169
})
170170
}
171171

172+
func badgerOptions(badgerDbPath string) badger.Options {
173+
opts := badger.DefaultOptions(badgerDbPath)
174+
opts.DetectConflicts = false
175+
opts.CompactL0OnClose = true
176+
opts.MetricsEnabled = false
177+
opts.Logger = &badgerLogger{log}
178+
return opts
179+
}
180+
172181
// NewTicketPool constructs a TicketPool by opening the persistent diff db,
173182
// loading all known diffs, initializing the TicketPool values.
174183
func NewTicketPool(dataDir, dbSubDir string) (tp *TicketPool, err error) {
175184
// Open ticket pool diffs database
176185
badgerDbPath := filepath.Join(dataDir, dbSubDir)
177-
opts := badger.DefaultOptions(badgerDbPath)
178-
opts.MetricsEnabled = false
179-
opts.Logger = &badgerLogger{log}
186+
opts := badgerOptions(badgerDbPath)
180187
db, err := badger.Open(opts)
181188
if err != nil {
182189
if !strings.Contains(err.Error(), "manifest has unsupported version") {

stakedb/upgrade.go

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -259,9 +259,7 @@ func v2Upgrade(dbPath string) error {
259259
return fmt.Errorf("failed to delete db file: %w", err)
260260
}
261261

262-
opts := badger.DefaultOptions(dbPath)
263-
opts.MetricsEnabled = false
264-
opts.Logger = &badgerLogger{log}
262+
opts := badgerOptions(dbPath)
265263
db, err := badger.Open(opts)
266264
if err != nil {
267265
return err

0 commit comments

Comments
 (0)