(ctx context.Context, userLogger log.Logger, userBucket objstore.InstrumentedBucket)
| 574 | } |
| 575 | |
| 576 | func (c *BlocksCleaner) deleteNonDataFiles(ctx context.Context, userLogger log.Logger, userBucket objstore.InstrumentedBucket) error { |
| 577 | begin := time.Now() |
| 578 | if deleted, err := bucket.DeletePrefix(ctx, userBucket, block.DebugMetas, userLogger, defaultDeleteBlocksConcurrency); err != nil { |
| 579 | return errors.Wrap(err, "failed to delete "+block.DebugMetas) |
| 580 | } else if deleted > 0 { |
| 581 | level.Info(userLogger).Log("msg", "deleted files under "+block.DebugMetas+" for tenant marked for deletion", "count", deleted, "duration", time.Since(begin), "duration_ms", time.Since(begin).Milliseconds()) |
| 582 | } |
| 583 | |
| 584 | if c.cfg.CompactionStrategy == util.CompactionStrategyPartitioning { |
| 585 | begin = time.Now() |
| 586 | // Clean up partitioned group info files |
| 587 | if deleted, err := bucket.DeletePrefix(ctx, userBucket, PartitionedGroupDirectory, userLogger, defaultDeleteBlocksConcurrency); err != nil { |
| 588 | return errors.Wrap(err, "failed to delete "+PartitionedGroupDirectory) |
| 589 | } else if deleted > 0 { |
| 590 | level.Info(userLogger).Log("msg", "deleted files under "+PartitionedGroupDirectory+" for tenant marked for deletion", "count", deleted, "duration", time.Since(begin), "duration_ms", time.Since(begin).Milliseconds()) |
| 591 | } |
| 592 | } |
| 593 | return nil |
| 594 | } |
| 595 | |
| 596 | func (c *BlocksCleaner) cleanUser(ctx context.Context, userLogger log.Logger, userBucket objstore.InstrumentedBucket, userID string, firstRun bool) (returnErr error) { |
| 597 | c.blocksMarkedForDeletion.WithLabelValues(userID, reasonValueRetention) |
no test coverage detected