diff --git a/tsdb/head.go b/tsdb/head.go index 4352d86d9e..db40eb89e8 100644 --- a/tsdb/head.go +++ b/tsdb/head.go @@ -752,6 +752,11 @@ func (h *Head) Init(minValidTime int64) error { return nil } +// SetMinValidTime sets the minimum timestamp the head can ingest. +func (h *Head) SetMinValidTime(minValidTime int64) { + h.minValidTime.Store(minValidTime) +} + func (h *Head) loadMmappedChunks() (map[uint64][]*mmappedChunk, error) { mmappedChunks := map[uint64][]*mmappedChunk{} if err := h.chunkDiskMapper.IterateAllChunks(func(seriesRef, chunkRef uint64, mint, maxt int64, numSamples uint16) error {