[rhmessaging-commits] rhmessaging commits: r2287 - mgmt/trunk/cumin/python/cumin.

rhmessaging-commits at lists.jboss.org rhmessaging-commits at lists.jboss.org
Tue Aug 12 17:37:07 EDT 2008


Author: justi9
Date: 2008-08-12 17:37:06 -0400 (Tue, 12 Aug 2008)
New Revision: 2287

Added:
   mgmt/trunk/cumin/python/cumin/pool.py
   mgmt/trunk/cumin/python/cumin/pool.strings
Modified:
   mgmt/trunk/cumin/python/cumin/model.py
   mgmt/trunk/cumin/python/cumin/page.py
   mgmt/trunk/cumin/python/cumin/parameters.py
Log:
Add basic navigation for grid pools

Modified: mgmt/trunk/cumin/python/cumin/model.py
===================================================================
--- mgmt/trunk/cumin/python/cumin/model.py	2008-08-12 21:35:11 UTC (rev 2286)
+++ mgmt/trunk/cumin/python/cumin/model.py	2008-08-12 21:37:06 UTC (rev 2287)
@@ -36,6 +36,7 @@
 
         CuminBrokerRegistration(self)
         CuminBrokerGroup(self)
+        CuminPool(self)
 
     def check(self):
         self.data.check()
@@ -1353,6 +1354,16 @@
     def get_icon_href(self, session):
         return "resource?name=group-36.png"
 
+class CuminPool(CuminClass):
+    def __init__(self, model):
+        super(CuminPool, self).__init__(model, "pool", Pool)
+
+    def get_title(self, session):
+        return "Pool"
+
+    def show_object(self, session, pool):
+        return self.cumin_model.show_main(session).show_pool(session, pool)
+
 class ModelPage(Page):
     def __init__(self, app, name):
         super(ModelPage, self).__init__(app, name)

Modified: mgmt/trunk/cumin/python/cumin/page.py
===================================================================
--- mgmt/trunk/cumin/python/cumin/page.py	2008-08-12 21:35:11 UTC (rev 2286)
+++ mgmt/trunk/cumin/python/cumin/page.py	2008-08-12 21:37:06 UTC (rev 2287)
@@ -7,6 +7,7 @@
 from brokergroup import *
 from brokerprofile import *
 from brokercluster import *
+from pool import *
 from system import *
 from action import *
 from widgets import *
@@ -89,6 +90,9 @@
         self.__cluster = BrokerClusterFrame(app, "cluster")
         self.add_mode(self.__cluster)
 
+        self.__pool = PoolFrame(app, "pool")
+        self.add_mode(self.__pool)
+
         self.__system = SystemFrame(app, "system")
         self.add_mode(self.__system)
 
@@ -159,6 +163,11 @@
         frame.set_object(session, cluster)
         return self.page.set_current_frame(session, frame)
 
+    def show_pool(self, session, pool):
+        frame = self.show_mode(session, self.__pool)
+        frame.set_object(session, pool)
+        return self.page.set_current_frame(session, frame)
+
     def show_system(self, session, system):
         frame = self.show_mode(session, self.__system)
         frame.set_object(session, system)
@@ -198,7 +207,7 @@
         self.add_parameter(self.selection)
 
         self.add_link(self.MessagingTab(app, "mtab"))
-        #self.add_link(self.GridTab(app, "gtab"))
+        self.add_link(self.GridTab(app, "gtab"))
         self.add_link(self.SystemsTab(app, "stab"))
 
     def render_class(self, session):
@@ -278,6 +287,11 @@
             return "Tags"
 
 class GridView(TabbedModeSet):
+    def __init__(self, app, name):
+        super(GridView, self).__init__(app, name)
+
+        self.add_tab(PoolSet(app, "pools"))
+
     def render_title(self, session):
         return "Grid"
 

Modified: mgmt/trunk/cumin/python/cumin/parameters.py
===================================================================
--- mgmt/trunk/cumin/python/cumin/parameters.py	2008-08-12 21:35:11 UTC (rev 2286)
+++ mgmt/trunk/cumin/python/cumin/parameters.py	2008-08-12 21:37:06 UTC (rev 2287)
@@ -72,6 +72,13 @@
     def do_marshal(self, peer):
         return str(peer.id)
 
+class PoolParameter(Parameter):
+    def do_unmarshal(self, string):
+        return Pool.get(int(string))
+
+    def do_marshal(self, pool):
+        return str(pool.id)
+
 class QueueParameter(Parameter):
     def do_unmarshal(self, string):
         return Queue.get(int(string))

Added: mgmt/trunk/cumin/python/cumin/pool.py
===================================================================
--- mgmt/trunk/cumin/python/cumin/pool.py	                        (rev 0)
+++ mgmt/trunk/cumin/python/cumin/pool.py	2008-08-12 21:37:06 UTC (rev 2287)
@@ -0,0 +1,63 @@
+import logging
+
+from wooly import *
+from wooly.widgets import *
+from wooly.forms import *
+from wooly.resources import *
+from wooly.tables import *
+
+from stat import *
+from widgets import *
+from parameters import *
+from formats import *
+from util import *
+
+strings = StringCatalog(__file__)
+log = logging.getLogger("cumin.pool")
+
+class PoolSet(CuminTable):
+    def __init__(self, app, name):
+        super(PoolSet, self).__init__(app, name)
+
+        col = self.NameColumn(app, "name")
+        self.add_column(col)
+
+        self.set_default_column(col)
+
+    def render_title(self, session):
+        return "Pools %s" % fmt_count(Pool.select().count())
+
+    class NameColumn(SqlTableColumn):
+        def render_title(self, session, data):
+            return "Name"
+
+        def render_content(self, session, data):
+            pool = Identifiable(data["id"])
+            branch = session.branch()
+            self.frame.show_pool(branch, pool).show_view(branch)
+            return fmt_olink(branch, pool, name=data["name"])
+
+class PoolFrame(CuminFrame):
+    def __init__(self, app, name):
+        super(PoolFrame, self).__init__(app, name)
+
+        self.object = PoolParameter(app, "id")
+        self.add_parameter(self.object)
+
+        view = PoolView(app, "view")
+        self.add_mode(view)
+        self.set_view_mode(view)
+
+class PoolView(CuminView):
+    def __init__(self, app, name):
+        super(PoolView, self).__init__(app, name)
+
+        status = PoolStatus(app, "status")
+        self.add_child(status)
+
+        self.__tabs = TabbedModeSet(app, "tabs")
+        self.add_child(self.__tabs)
+
+class PoolStatus(CuminStatus):
+    pass
+

Added: mgmt/trunk/cumin/python/cumin/pool.strings
===================================================================
--- mgmt/trunk/cumin/python/cumin/pool.strings	                        (rev 0)
+++ mgmt/trunk/cumin/python/cumin/pool.strings	2008-08-12 21:37:06 UTC (rev 2287)
@@ -0,0 +1,8 @@
+[PoolSet.sql]
+select
+  p.id,
+  p.name
+from pool as p
+
+[PoolSet.count_sql]
+select count(*) from pool




More information about the rhmessaging-commits mailing list