Function
NewCompactionProvider
(
cfg CompactionConfig,
logger log.Logger,
store storage.Store,
overrides overrides.Interface,
scheduler Scheduler,
)
Source from the content-addressed store, hash-verified
| 71 | } |
| 72 | |
| 73 | func NewCompactionProvider( |
| 74 | cfg CompactionConfig, |
| 75 | logger log.Logger, |
| 76 | store storage.Store, |
| 77 | overrides overrides.Interface, |
| 78 | scheduler Scheduler, |
| 79 | ) *CompactionProvider { |
| 80 | return &CompactionProvider{ |
| 81 | cfg: cfg, |
| 82 | logger: logger, |
| 83 | store: store, |
| 84 | overrides: overrides, |
| 85 | curPriority: tenantselector.NewPriorityQueue(), |
| 86 | sched: scheduler, |
| 87 | } |
| 88 | } |
| 89 | |
| 90 | func (p *CompactionProvider) Start(ctx context.Context) <-chan *work.Job { |
| 91 | jobs := make(chan *work.Job, 1) |