Make journald emit map[string]interface{}

observIQ · Jul 17, 2020 · 17e18fc · 17e18fc
1 parent 89dbd2e
commit 17e18fc
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/plugin/builtin/input/journald.go b/plugin/builtin/input/journald.go
@@ -162,7 +162,7 @@ func (plugin *JournaldInput) Start() error {
 }
 
 func (plugin *JournaldInput) parseJournalEntry(line []byte) (*entry.Entry, string, error) {
-	var record map[string]string
+	var record map[string]interface{}
 	err := plugin.json.Unmarshal(line, &record)
 	if err != nil {
 		return nil, "", err
@@ -173,7 +173,7 @@ func (plugin *JournaldInput) parseJournalEntry(line []byte) (*entry.Entry, strin
 		return nil, "", errors.New("journald record missing __REALTIME_TIMESTAMP field")
 	}
 
-	timestampInt, err := strconv.ParseInt(timestamp, 10, 64)
+	timestampInt, err := strconv.ParseInt(timestamp.(string), 10, 64)
 	if err != nil {
 		return nil, "", fmt.Errorf("parse timestamp: %s", err)
 	}
@@ -187,7 +187,7 @@ func (plugin *JournaldInput) parseJournalEntry(line []byte) (*entry.Entry, strin
 
 	entry := plugin.NewEntry(record)
 	entry.Timestamp = time.Unix(0, timestampInt*1000) // in microseconds
-	return entry, cursor, nil
+	return entry, cursor.(string), nil
 }
 
 func (plugin *JournaldInput) syncOffsets() {