Support for namespace in graphite bridge prometheus#49

Vikas Kumar · Vikas Kumar · commit c5fff613e5b8 · 2015-10-03T12:17:45.000-07:00
1. Added an optional parameter `prefix` to `bridge.graphite.GraphiteBridge.push()`.
2. Initialize _RegularPush with `prefix`.
diff --git a/prometheus_client/bridge/graphite.py b/prometheus_client/bridge/graphite.py
@@ -19,10 +19,11 @@ def _sanitize(s):
 
 
 class _RegularPush(threading.Thread):
-    def __init__(self, pusher, interval):
+    def __init__(self, pusher, interval, prefix):
         super(_RegularPush, self).__init__()
         self._pusher = pusher
         self._interval = interval
+        self._prefix = prefix
 
     def run(self):
         wait_until = time.time()
@@ -37,7 +38,7 @@ def run(self):
                 # time.sleep can return early.
                 time.sleep(wait_until - now)
             try:
-                self._pusher.push()
+                self._pusher.push(prefix=self._prefix)
             except IOError:
                 logging.exception("Push failed")
 
@@ -73,7 +74,7 @@ def push(self, prefix=''):
         conn.sendall(''.join(output).encode('ascii'))
         conn.close()
 
-    def start(self, interval=60.0):
-        t = _RegularPush(self, interval)
+    def start(self, interval=60.0, prefix=''):
+        t = _RegularPush(self, interval, prefix)
         t.daemon = True
         t.start()
