commit 01ddea6bc9410076f3e3217a64382a77786aae9b
author Sapan Bhatia <gwsapan@gmail.com> Fri Feb 10 11:28:48 2017 -0800
committer Scott Baker <scottb@onlab.us> Tue Feb 14 22:10:25 2017 -0800
tree 18c19f4f12dc41c85e1a0964057acaeeb594b589
parent 19c61df83d9559593e291db71366e0951ce91e7d

CORD-705: ELK logging and debugger for CORD

Change-Id: I3406d95161e71976ee3b3bf689f89069b4d9de73

elk-logger/patterns.py

diff --git a/elk-logger/patterns.py b/elk-logger/patterns.py
new file mode 100644
index 0000000..5aff6f2
--- /dev/null
+++ b/elk-logger/patterns.py
@@ -0,0 +1,31 @@
+from pyparsing import *
+
+class Parser:
+    test_pattern = "{{{" + SkipTo("}}}",include=True)
+    test_pattern.setParseAction(lambda x:{"test":x[1][0]})
+
+    test_pattern2 = "1" + SkipTo(LineEnd(),include=True) + SkipTo(LineEnd(),include=True) + "2"
+    test_pattern2.setParseAction(lambda x:{"test":x[1]})
+
+    ansible = "TASK [" + SkipTo(']',include=True) + SkipTo(LineEnd(),include=True) + oneOf('changed ok failed error unreachable') + ': ' + SkipTo(LineEnd(),include=True)
+    ansible.setParseAction(lambda x:{"task":x[1][0],"status":x[3],"subject": x[5][0],"ansible":1})
+
+    ansible2 = "TASK [" + SkipTo(']',include=True) + SkipTo(LineEnd(),include=True) + SkipTo(LineEnd(),include=True) + oneOf('changed ok failed error unreachable') + ': ' + SkipTo(LineEnd(),include=True)
+    ansible2.setParseAction(lambda x:{"task":x[1][0],"status":x[4],"subject": x[6][0],"ansible":1})
+
+    ansible3 = "TASK [" + SkipTo(']',include=True) + SkipTo(LineEnd(),include=True) + SkipTo(LineEnd(),include=True) + SkipTo(LineEnd(),include=True) + oneOf('changed ok failed error unreachable') + ': ' + SkipTo(LineEnd(),include=True)
+    ansible3.setParseAction(lambda x:{"task":x[1][0],"status":x[5],"subject": x[7][0],"ansible":1})
+
+    # Vagrant
+    vagrant_start = Literal("[") + SkipTo("]",include=True) + "Importing base box '" + SkipTo("'",include=True) + SkipTo(LineEnd(),include=True)
+    vagrant_start.setParseAction(lambda x:{"vm":x[1][0],"image":x[3][0],"vagrant":1,"global":"Booting VM"})
+
+    vagrant_start = Literal("[") + SkipTo("]",include=True) + "Machine booted and ready!" + SkipTo(LineEnd(), include=True)
+    vagrant_start.setParseAction(lambda x:{"vm":x[1][0], "vagrant":1, "global":"VM Booted up"})
+
+    gradle_start = "Downloading https://services.gradle.org" + SkipTo(LineEnd(), include=True)
+    gradle_start.setParseAction(lambda x:{"gradle":1, "global":"Gradle started"})
+
+    debian_preparing = "Preparing to unpack" + Word(printables) + SkipTo(LineEnd(), include=True)
+    debian_preparing.setParseAction(lambda x:{"debian":1, "package":x[1]})
+