| 230 | } |
| 231 | |
| 232 | func (rw *readerWriter) compactOneJob(ctx context.Context, blockMetas []*backend.BlockMeta, tenantID string) error { |
| 233 | _, err := rw.CompactWithConfig(ctx, blockMetas, tenantID, rw.compactorCfg, rw.compactorSharder, rw.compactorOverrides) |
| 234 | return err |
| 235 | } |
| 236 | |
| 237 | func (rw *readerWriter) CompactWithConfig(ctx context.Context, blockMetas []*backend.BlockMeta, tenantID string, compactorCfg *CompactorConfig, compactorSharder CompactorSharder, compactorOverrides CompactorOverrides) ([]*backend.BlockMeta, error) { |
| 238 | level.Debug(rw.logger).Log("msg", "beginning compaction", "num blocks compacting", len(blockMetas)) |