Method MarkBlocklistCompacted

tempodb/compactor.go:351–364

MarkCompacted marks the old blocks as compacted and adds the new blocks to the blocklist. No backend changes are made.

(tenantID string, oldBlocks, newBlocks []*backend.BlockMeta)

// MarkCompacted marks the old blocks as compacted and adds the new blocks to the blocklist.  No backend changes are made.
func (rw *readerWriter) MarkBlocklistCompacted(tenantID string, oldBlocks, newBlocks []*backend.BlockMeta) error {
	// Converted outgoing blocks into compacted entries.
	newCompactions := make([]*backend.CompactedBlockMeta, 0, len(oldBlocks))
	for _, newBlock := range oldBlocks {
		newCompactions = append(newCompactions, &backend.CompactedBlockMeta{
			BlockMeta:     *newBlock,
			CompactedTime: time.Now(),
		})
	}

	rw.blocklist.Update(tenantID, newBlocks, oldBlocks, newCompactions, nil)

	return nil
}

func markCompacted(rw *readerWriter, tenantID string, oldBlocks, newBlocks []*backend.BlockMeta) error {
	// Check if we have any errors, but continue marking the blocks as compacted