Method blocksToDelete

pkg/ingester/ingester.go:579–605

blocksToDelete filters the input blocks and returns the blocks which are safe to be deleted from the ingester.

(blocks []*tsdb.Block)

// blocksToDelete filters the input blocks and returns the blocks which are safe to be deleted from the ingester.
func (u *userTSDB) blocksToDelete(blocks []*tsdb.Block) map[ulid.ULID]struct{} {
	if u.db == nil {
		return nil
	}
	deletable := tsdb.DefaultBlocksToDelete(u.db)(blocks)

	now := time.Now().UnixMilli()
	for _, b := range blocks {
		if now-b.MaxTime() >= u.blockRetentionPeriod {
			deletable[b.Meta().ULID] = struct{}{}
		}
	}

	if u.shipper == nil {
		return deletable
	}

	shippedBlocks := u.getCachedShippedBlocks()

	result := map[ulid.ULID]struct{}{}
	for shippedID := range shippedBlocks {
		if _, ok := deletable[shippedID]; ok {
			result[shippedID] = struct{}{}
		}
	}
	return result
}

// updateCachedShippedBlocks reads the shipper meta file and updates the cached shipped blocks.
func (u *userTSDB) updateCachedShippedBlocks() error {