I-16 -- Place time field of journald record to top level of entry.

2gis · Nov 16, 2021 · e1a09d4 · e1a09d4
1 parent d06989a
commit e1a09d4
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/dispatcher/workers/worker_journald.go b/dispatcher/workers/worker_journald.go
@@ -115,15 +115,14 @@ func (worker *workerJournald) entryProceed() error {
 	}
 
 	entryMap["SYSTEMD_UNIT"] = entryMap["_SYSTEMD_UNIT"]
-	entryMap[common.LabelTime] = time.Unix(0, usec*int64(time.Microsecond)).Format(time.RFC3339)
+
 	entryMap = entryMap.Filter(
 		"SYSLOG_IDENTIFIER",
 		"PRIORITY",
 		"SYSLOG_PID",
 		"SYSLOG_FACILITY",
 		"SYSTEMD_UNIT",
 		"MESSAGE",
-		common.LabelTime,
 	)
 
 	if worker.config.UserLogFieldsKey != "" {
@@ -138,6 +137,7 @@ func (worker *workerJournald) entryProceed() error {
 		result.Extend(worker.extends)
 	}
 
+	result[common.LabelTime] = time.Unix(0, usec*int64(time.Microsecond)).Format(time.RFC3339)
 	entryByteString, err := json.Marshal(result)
 
 	if err != nil {