Method PostDeletion

pkg/ingester/ingester.go:561–576

PostDeletion implements SeriesLifecycleCallback interface.

(metrics map[chunks.HeadSeriesRef]labels.Labels)

// PostDeletion implements SeriesLifecycleCallback interface.
func (u *userTSDB) PostDeletion(metrics map[chunks.HeadSeriesRef]labels.Labels) {
	u.instanceSeriesCount.Sub(int64(len(metrics)))

	for _, metric := range metrics {
		metricName, err := extract.MetricNameFromLabels(metric)
		if err != nil {
			// This should never happen because it has already been checked in PreCreation().
			continue
		}
		u.seriesInMetric.decreaseSeriesForMetric(metricName)
		u.labelSetCounter.decreaseSeriesLabelSet(u, metric)
		if u.postingCache != nil {
			u.postingCache.ExpireSeries(metric)
		}
	}
}

// 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{} {