moksha/apps/metrics/moksha/apps/metrics/streams/metrics_stream.py | 9 +++++++++
1 file changed, 9 insertions(+)
New commits:
commit b2c5fd99eb6d48fe89778adc2e54f96f03f225c6
Author: Luke Macken <lmacken(a)redhat.com>
Date: Tue Mar 15 16:50:56 2011 -0400
Make the Metrics data producer configurable
diff --git a/moksha/apps/metrics/moksha/apps/metrics/streams/metrics_stream.py
b/moksha/apps/metrics/moksha/apps/metrics/streams/metrics_stream.py
index e841f30..ab4c59a 100644
--- a/moksha/apps/metrics/moksha/apps/metrics/streams/metrics_stream.py
+++ b/moksha/apps/metrics/moksha/apps/metrics/streams/metrics_stream.py
@@ -15,11 +15,17 @@
# limitations under the License.
import os
+import logging
import subprocess
+from tg import config
+from paste.deploy.converters import asbool
+
from moksha.lib.helpers import defaultdict
from moksha.api.streams import PollingDataStream
+log = logging.getLogger('moksha.hub')
+
PID = 0
NAME = -1
MEM_TOTAL = -2
@@ -36,6 +42,9 @@ class MokshaMetricsDataStream(PollingDataStream):
poll_for_new_pids = False
def __init__(self):
+ if not asbool(config.get('moksha.metrics_stream', False)):
+ log.info('Moksha Metrics Stream disabled')
+ return
self.programs = self._find_programs()
self.processors = self._find_processors()
super(MokshaMetricsDataStream, self).__init__()
Show replies by date