re
/
logrus
forked from mirror/logrus
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix race

This commit is contained in:
Max Lavrenov 2016-04-15 18:22:24 +03:00
parent 7e6f976580
commit 8a870e4f7b
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
formatters/logstash/logstash.go
View File

@ -24,11 +24,13 @@ func (f *LogstashFormatter) Format(entry *logrus.Entry) ([]byte, error) {
fields["@version"] = 1 fields["@version"] = 1
if f.TimestampFormat == "" { timeStampFormat := f.TimestampFormat
f.TimestampFormat = logrus.DefaultTimestampFormat
if timeStampFormat == "" {
timeStampFormat = logrus.DefaultTimestampFormat
} }
fields["@timestamp"] = entry.Time.Format(f.TimestampFormat) fields["@timestamp"] = entry.Time.Format(timeStampFormat)
// set message field // set message field
v, ok := entry.Data["message"] v, ok := entry.Data["message"]