EnableCompactions enables auto compactions.
()
| 2292 | |
| 2293 | // EnableCompactions enables auto compactions. |
| 2294 | func (db *DB) EnableCompactions() { |
| 2295 | db.autoCompactMtx.Lock() |
| 2296 | defer db.autoCompactMtx.Unlock() |
| 2297 | |
| 2298 | db.autoCompact = true |
| 2299 | db.logger.Info("Compactions enabled") |
| 2300 | } |
| 2301 | |
| 2302 | func (db *DB) generateCompactionDelay() time.Duration { |
| 2303 | return time.Duration(rand.Int63n(db.head.chunkRange.Load()*int64(db.opts.CompactionDelayMaxPercent)/100)) * time.Millisecond |