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"`