Merge lp:~cprov/core-image-watcher/logstash into lp:core-image-watcher

[Celso Providelo]

Adding logstash logging support.

Adding logstash logging support.

I am only doing this because I want to play with CI/CD, really ...

[Para Siva (psivaa)]

Thanks for the doc and the example config. +1.

review: Approve

[lp:~cprov/core-image-watcher/logstash]

8. By Celso Providelo on 2015-03-27

Adding logstash logging support. [r=Parameswaran Sivatharman]

=== modified file 'README.rst'
--- README.rst	2015-03-26 17:55:33 +0000
+++ README.rst	2015-03-27 14:01:01 +0000
@@ -66,3 +66,10 @@
    device = generic_amd64
    location = /tmp/latest-core-image-version
    poll_period = 60
+
+   [logstash]
+   host = 127.0.0.1
+   port = 5959
+   version = 1
+
+`logstash` section is optional.

=== modified file 'core-service.conf'
--- core-service.conf	2015-03-26 12:58:33 +0000
+++ core-service.conf	2015-03-27 14:01:01 +0000
@@ -8,3 +8,9 @@
 device = generic_amd64
 location = /tmp/latest-core-image-version
 poll_period = 60
+
+[logstash]
+host = 127.0.0.1
+port = 5959
+version = 1
+

=== modified file 'core_image_watcher/__init__.py'
--- core_image_watcher/__init__.py	2015-03-27 04:20:18 +0000
+++ core_image_watcher/__init__.py	2015-03-27 14:01:01 +0000
@@ -26,6 +26,8 @@
 import time
 
 import kombu
+import logstash
+
 
 logger = logging.getLogger(__name__)
 
@@ -147,6 +149,15 @@
     )
     root_logger.addHandler(handler)
 
+    if 'logstash' in config:
+        root_logger.addHandler(
+            logstash.LogstashHandler(
+                config['logstash']['host'],
+                int(config['logstash']['port']),
+                int(config['logstash']['version'])
+            )
+        )
+
 
 def main():
     parser = argparse.ArgumentParser(

=== modified file 'requirements.txt'
--- requirements.txt	2015-03-25 13:52:28 +0000
+++ requirements.txt	2015-03-27 14:01:01 +0000
@@ -1,1 +1,2 @@
 kombu==3.0.24
+python-logstash==0.4.2