From b3d5df1e6b52d30782c1ba6b65864df18b3b8055 Mon Sep 17 00:00:00 2001 From: bwplotka Date: Fri, 27 Dec 2024 12:21:26 +0000 Subject: [PATCH] populate CT from metadata. Signed-off-by: bwplotka --- storage/remote/queue_manager.go | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/storage/remote/queue_manager.go b/storage/remote/queue_manager.go index b1c8997268..6d6144cba7 100644 --- a/storage/remote/queue_manager.go +++ b/storage/remote/queue_manager.go @@ -1007,9 +1007,10 @@ func (t *QueueManager) StoreMetadata(meta []record.RefMetadata) { defer t.seriesMtx.Unlock() for _, m := range meta { t.seriesMetadata[m.Ref] = &metadata.Metadata{ - Type: record.ToMetricType(m.Type), - Unit: m.Unit, - Help: m.Help, + Type: record.ToMetricType(m.Type), + Unit: m.Unit, + Help: m.Help, + CreatedTimestamp: m.CreatedTimestamp, } } } @@ -1943,11 +1944,12 @@ func populateV2TimeSeries(symbolTable *writev2.SymbolsTable, batch []timeSeries, var nPendingSamples, nPendingExemplars, nPendingHistograms, nPendingMetadata int for nPending, d := range batch { pendingData[nPending].Samples = pendingData[nPending].Samples[:0] - // todo: should we also safeguard against empty metadata here? + // TODO: should we also safeguard against empty metadata here? if d.metadata != nil { pendingData[nPending].Metadata.Type = writev2.FromMetadataType(d.metadata.Type) pendingData[nPending].Metadata.HelpRef = symbolTable.Symbolize(d.metadata.Help) pendingData[nPending].Metadata.HelpRef = symbolTable.Symbolize(d.metadata.Unit) + pendingData[nPending].CreatedTimestamp = d.metadata.CreatedTimestamp nPendingMetadata++ }