From b2d49d00f934a5a73fa7ae363d93cd6f1ab837b6 Mon Sep 17 00:00:00 2001 From: Frank van Lankvelt Date: Mon, 24 Jun 2024 13:29:22 +0200 Subject: [PATCH] STAC-21424: send timeformat header so collection timestamp is interpreted correctly --- exporter/ststopologyexporter/exporter.go | 1 + exporter/ststopologyexporter/exporter_test.go | 1 + 2 files changed, 2 insertions(+) diff --git a/exporter/ststopologyexporter/exporter.go b/exporter/ststopologyexporter/exporter.go index 782f351..bb56bc6 100644 --- a/exporter/ststopologyexporter/exporter.go +++ b/exporter/ststopologyexporter/exporter.go @@ -160,6 +160,7 @@ func (t *topologyExporter) ConsumeMetrics(ctx context.Context, md pmetric.Metric } req.Header.Add("Content-Type", "application/json") req.Header.Add("sts-api-key", apiKey) + req.Header.Add("sts-time-format", "ms") res, err := t.httpClient.Do(req) if err != nil { diff --git a/exporter/ststopologyexporter/exporter_test.go b/exporter/ststopologyexporter/exporter_test.go index f7eb0f3..3033e87 100644 --- a/exporter/ststopologyexporter/exporter_test.go +++ b/exporter/ststopologyexporter/exporter_test.go @@ -18,6 +18,7 @@ import ( func TestExporter_pushResourcesData(t *testing.T) { testServer := httptest.NewServer(http.HandlerFunc(func(res http.ResponseWriter, req *http.Request) { require.Equal(t, "APIKEY", req.Header[http.CanonicalHeaderKey("sts-api-key")][0]) + require.Equal(t, "ms", req.Header[http.CanonicalHeaderKey("sts-time-format")][0]) var payload internal.IntakeTopology err := json.NewDecoder(req.Body).Decode(&payload)