From bd28c2c1bcb1a2d923a1b5d4f4b3f28a96675492 Mon Sep 17 00:00:00 2001
From: Mathieu Lecarme <mathieu@garambrogne.net>
Date: Tue, 7 Jun 2022 15:54:01 +0200
Subject: [PATCH] Fix: specific entry unmarshal

---
 pkg/acquisition/modules/loki/entry.go | 21 ++++++++++++++++++++-
 1 file changed, 20 insertions(+), 1 deletion(-)

diff --git a/pkg/acquisition/modules/loki/entry.go b/pkg/acquisition/modules/loki/entry.go
index 0ac89bb4c..98ffd863b 100644
--- a/pkg/acquisition/modules/loki/entry.go
+++ b/pkg/acquisition/modules/loki/entry.go
@@ -1,12 +1,31 @@
 package loki
 
-import "time"
+import (
+	"encoding/json"
+	"strconv"
+	"time"
+)
 
 type Entry struct {
 	Timestamp time.Time
 	Line      string
 }
 
+func (e *Entry) UnmarshalJSON(b []byte) error {
+	var values []string
+	err := json.Unmarshal(b, &values)
+	if err != nil {
+		return err
+	}
+	t, err := strconv.Atoi(values[0])
+	if err != nil {
+		return err
+	}
+	e.Timestamp = time.Unix(int64(t), 0)
+	e.Line = values[1]
+	return nil
+}
+
 type Stream struct {
 	Stream  map[string]string `json:"stream"`
 	Entries []Entry           `json:"values"`