From fdc0ec232d62993f9f2bfaf03cdf9cb605bdc509 Mon Sep 17 00:00:00 2001
From: "James E. Blair" <jeblair@openstack.org>
Date: Mon, 24 Feb 2014 15:34:48 -0800
Subject: [PATCH] Use statsd in logstash client

Have the log-gearman-client (aka jenkins-log-client) initialize
the statsd parameters when starting the geard server.  Also, make
sure that the python statsd package is installed on the host.

Change-Id: I04fe1a7609f08bc710891b6a3b92d0f4d156d86c
---
 modules/log_processor/files/log-gearman-client.py | 8 +++++++-
 modules/log_processor/manifests/init.pp           | 6 ++++++
 2 files changed, 13 insertions(+), 1 deletion(-)

diff --git a/modules/log_processor/files/log-gearman-client.py b/modules/log_processor/files/log-gearman-client.py
index 0f36649aec..a472c19de0 100644
--- a/modules/log_processor/files/log-gearman-client.py
+++ b/modules/log_processor/files/log-gearman-client.py
@@ -148,7 +148,13 @@ class Server(object):
             self.processors.append(processor)
 
     def main(self):
-        self.gearserver = gear.Server()
+        statsd_host = os.environ.get('STATSD_HOST')
+        statsd_port = int(os.environ.get('STATSD_PORT', 8125))
+        statsd_prefix = os.environ.get('STATSD_PREFIX', 'logstash.geard')
+        self.gearserver = gear.Server(
+            statsd_host=statsd_host,
+            statsd_port=statsd_port,
+            statsd_prefix=statsd_prefix)
 
         self.setup_processors()
         for processor in self.processors:
diff --git a/modules/log_processor/manifests/init.pp b/modules/log_processor/manifests/init.pp
index e69f9d010d..661ca0ed6d 100644
--- a/modules/log_processor/manifests/init.pp
+++ b/modules/log_processor/manifests/init.pp
@@ -40,6 +40,12 @@ class log_processor (
     require  => Class['pip'],
   }
 
+  package { 'statsd':
+    ensure   => latest,
+    provider => 'pip',
+    require  => Class['pip'],
+  }
+
   file { '/var/lib/crm114':
     ensure  => directory,
     owner   => 'logstash',