Merge remote-tracking branch 'sasha/master'

- node-status

1 files changed, 22 insertions, 0 deletions

diff --git a/python/pgq/cascade/admin.py b/python/pgq/cascade/admin.py
index 97e52f07..80064774 100644
--- a/python/pgq/cascade/admin.py
+++ b/python/pgq/cascade/admin.py
@@ -36,6 +36,7 @@ Node Administration:
   wait-root             Wait until node has catched up to root
   wait-provider         Wait until node has catched up to provider
   status                Show cascade state
+  node-status           Show status of a local node
   members               Show members in set
 
 Cascade layout change:
@@ -381,6 +382,27 @@ class CascadeAdmin(skytools.AdminScript):
 
         self.queue_info.print_tree()
 
+    def cmd_node_status(self):
+        """
+        Show status of a local node.
+        """
+
+        self.load_local_info()
+        db = self.get_node_database(self.local_node)
+        curs = db.cursor()
+        node = self.queue_info.local_node
+        node.load_status(curs)
+        self.load_extra_status(curs, node)
+
+        subscriber_nodes = self.get_node_subscriber_list(self.local_node)
+
+        offset=4*' '
+        print node.get_title()
+        print offset+'Provider: %s' % node.provider_node
+        print offset+'Subscribers: %s' % ', '.join(subscriber_nodes)
+        for l in node.get_infolines():
+            print offset+l
+
     def load_extra_status(self, curs, node):
         """Fetch extra info."""
         pass