Method deleteOldBlocks

modules/livestore/instance.go:695–740

()

}

func (i *instance) deleteOldBlocks() error {
	i.blocksMtx.Lock()
	defer i.blocksMtx.Unlock()

	cutoff := time.Now().Add(-i.Cfg.CompleteBlockTimeout) // Delete blocks older than Complete Block Timeout

	snap := i.blocks.Load()
	newSnap := snap
	defer func() {
		if newSnap != snap {
			i.blocks.Store(newSnap)
		}
	}()

	for id, walBlock := range snap.walBlocks {
		if walBlock.BlockMeta().EndTime.Before(cutoff) {
			if _, ok := snap.completeBlocks[id]; !ok {
				level.Warn(i.logger).Log("msg", "deleting WAL block that was never completed", "block", id.String())
			}
			if err := walBlock.Tombstone(); err != nil {
				return err
			}
			newSnap = newSnap.withWALBlockRemoved(id)
			wb := walBlock
			i.reclaim.add(id, i.tenantID, "wal", func() error { return wb.Clear() })
		}
	}

	for id, completeBlock := range snap.completeBlocks {
		if !i.completeBlockLifecycle.shouldDeleteCompleteBlock(completeBlock, cutoff) {
			continue
		}

		level.Info(i.logger).Log("msg", "deleting complete block", "block", id.String())
		if err := i.wal.LocalBackend().TombstoneBlock(id, i.tenantID); err != nil {
			return err
		}
		newSnap = newSnap.withCompleteBlockRemoved(id)
		bid := id
		tenant := i.tenantID
		bk := i.wal.LocalBackend()
		i.reclaim.add(bid, tenant, "complete", func() error { return bk.ClearBlock(bid, tenant) })
	}

	return nil
}