From 821d2f817620ff379bc7f00a0e9c2c785c07e4d1 Mon Sep 17 00:00:00 2001 From: Ralph Bean Date: Thu, 25 Sep 2014 13:21:01 +0000 Subject: [PATCH] Support sending new moksha stats into collectd. --- .../templates/fedmsg-service-collectd.py | 18 ++++++++++++++++++ 1 file changed, 18 insertions(+) diff --git a/roles/collectd/fedmsg-service/templates/fedmsg-service-collectd.py b/roles/collectd/fedmsg-service/templates/fedmsg-service-collectd.py index 69b612b474..171922e332 100644 --- a/roles/collectd/fedmsg-service/templates/fedmsg-service-collectd.py +++ b/roles/collectd/fedmsg-service/templates/fedmsg-service-collectd.py @@ -30,6 +30,24 @@ def print_consumer(service, consumer): timestamp, consumer['exceptions'] ) + # These got introduced in a later version of moksha, so not every host has them + if 'headcount_in' in consumer: + print "PUTVAL %s/%s/gauge-%s interval=5 %i:%i" % ( + hostname, + service, + '%s_in' % consumer['name'], + timestamp, + consumer['headcount_in'] + ) + + if 'headcount_out' in consumer: + print "PUTVAL %s/%s/gauge-%s interval=5 %i:%i" % ( + hostname, + service, + '%s_out' % consumer['name'], + timestamp, + consumer['headcount_out'] + ) def print_producer(service, producer):