commit 137f5a93edb54d7ae5a014f77f529c8346c589e0
author Ildar Svetlov <isvetlov@mirantis.com> Mon Jan 22 15:24:11 2018 +0400
committer Ildar Svetlov <isvetlov@mirantis.com> Mon Jan 22 15:24:11 2018 +0400
tree 1ee46be635143f4b4b746359b3286d2edfe111d2
parent 0baf0a3ada0b52c8455290e278388157dd179960

Parse multiline contrail_supervisor logs

Change-Id: Ibc94ae901dac3df54de09f081fa6fe77d413d386

heka/files/lua/decoders/contrail_supervisor_log.lua

diff --git a/heka/files/lua/decoders/contrail_supervisor_log.lua b/heka/files/lua/decoders/contrail_supervisor_log.lua
index a108fa5..d0658ee 100644
--- a/heka/files/lua/decoders/contrail_supervisor_log.lua
+++ b/heka/files/lua/decoders/contrail_supervisor_log.lua
@@ -29,7 +29,7 @@
 
 local timestamp_grammar = l.Cg(patt.Timestamp, "Timestamp")
 local SeverityLabel = l.Cg(patt.SeverityLabel + l.P"CRIT" + l.P"WARN", "SeverityLabel")
-local grammar = l.Ct(timestamp_grammar * patt.sp * SeverityLabel * l.Cg(patt.Message, "Message"))
+local grammar = l.Ct(timestamp_grammar * patt.sp * SeverityLabel * l.Cg(patt.Message / utils.chomp, "Message"))
 
 function process_message ()
     local log = read_message("Payload")