Method runDeleteUserCleanup

pkg/compactor/blocks_cleaner.go:368–378

(ctx context.Context, jobChan chan *cleanerJob)

}

func (c *BlocksCleaner) runDeleteUserCleanup(ctx context.Context, jobChan chan *cleanerJob) {
	for job := range jobChan {
		if job.timestamp < time.Now().Add(-c.cfg.CleanupInterval).Unix() {
			level.Warn(c.logger).Log("Delete users cleaner job too old. Ignoring to get recent data")
			continue
		}
		err := c.cleanDeletedUsers(ctx, job.users)

		c.checkRunError(deletedStatus, err)
	}
}

func (c *BlocksCleaner) cleanDeletedUsers(ctx context.Context, users []string) error {
	level.Info(c.logger).Log("msg", "started blocks cleanup and maintenance for deleted users")