From 404d85f7a819ab8557b5ecb169d129b49801bdb8 Mon Sep 17 00:00:00 2001 From: Goutham Veeramachaneni Date: Thu, 18 Feb 2021 06:22:35 +0100 Subject: [PATCH] Add ability to set minValidTime in TSDB (#8415) Signed-off-by: Goutham Veeramachaneni * Review feedback Signed-off-by: Goutham Veeramachaneni --- tsdb/head.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/tsdb/head.go b/tsdb/head.go index 4352d86d9..db40eb89e 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 {