Method perTenantCleanupLoop

modules/livestore/live_store_background.go:215–250

(inst *instance)

}

func (s *LiveStore) perTenantCleanupLoop(inst *instance) {
	// ticker
	ticker := time.NewTicker(s.cfg.InstanceCleanupPeriod)
	defer ticker.Stop()

	// Reclaim at a fraction of the grace window so blocks are deleted
	// soon after expiry, not at the next InstanceCleanupPeriod tick.
	reclaimInterval := s.cfg.BlockReclaimGrace / 4
	if reclaimInterval < time.Second {
		reclaimInterval = time.Second
	}
	reclaimTicker := time.NewTicker(reclaimInterval)
	defer reclaimTicker.Stop()

	for {
		select {
		case <-ticker.C:
			// dump any blocks that have been flushed for a while
			err := inst.deleteOldBlocks()
			if err != nil {
				level.Error(s.logger).Log("msg", "failed to delete old blocks", "err", err)
			}
		case <-reclaimTicker.C:
			for _, r := range inst.reclaim.reclaim() {
				if r.Err != nil {
					level.Error(s.logger).Log("msg", "reclaim failed", "tenant", r.Tenant, "block_id", r.BlockID.String(), "block_type", r.BlockType, "err", r.Err)
					continue
				}
				metricBlocksClearedTotal.WithLabelValues(r.BlockType).Inc()
				level.Info(s.logger).Log("msg", "reclaimed block", "tenant", r.Tenant, "block_id", r.BlockID.String(), "block_type", r.BlockType)
			}
		case <-s.ctx.Done():
			return
		}
	}
}

func (s *LiveStore) enqueueCompleteOp(tenantID string, blockID uuid.UUID, jitter bool) error {
	op := &completeOp{