()
| 573 | } |
| 574 | |
| 575 | func (rw *readerWriter) Shutdown() { |
| 576 | // Closed only by context cancelation when the poller is finished. |
| 577 | if rw.pollerShutdownCh != nil { |
| 578 | <-rw.pollerShutdownCh |
| 579 | } |
| 580 | rw.pool.Shutdown() |
| 581 | rw.r.Shutdown() |
| 582 | } |
| 583 | |
| 584 | // EnableCompaction activates the compaction/retention loops |
| 585 | func (rw *readerWriter) EnableCompaction(ctx context.Context, cfg *CompactorConfig, c CompactorSharder, overrides CompactorOverrides) error { |