Track in graphite new Cassandra connections being opened.

2026-01-23 22:08:11 -05:00 · 2012-06-21 15:37:07 -07:00
parent 42c4e91f3a
commit d579592ea7
1 changed files with 3 additions and 0 deletions
--- a/r2/r2/lib/stats.py
+++ b/r2/r2/lib/stats.py
@@ -222,6 +222,9 @@ class StatsCollectingConnectionPool(pool.ConnectionPool):
        self.stats = stats

    def _get_new_wrapper(self, server):
+        host, sep, port = server.partition(':')
+        self.stats.event_count('cassandra.connections', host)
+
        cf_types = (columnfamily.ColumnParent, columnfamily.ColumnPath)

        def get_cf_name_from_args(args, kwargs):