Unterschiede

Hier werden die Unterschiede zwischen zwei Versionen angezeigt.

--- nosql:admin_console_oracle_nosql_db_11gr2 [2013/07/01 07:08] – angelegt gpipperr
+++ nosql:admin_console_oracle_nosql_db_11gr2 [2013/07/04 18:03] – gpipperr
@@ Zeile 28: / Zeile 28: @@
     }
+</code>
+Beispiel für den Aufruf der Performance Statistik ohne den lästigen Header der Amin Konsole:
+<code java>
     /**
@@ Zeile 54: / Zeile 59: @@
     }
+</code>
+Beispiel für die Anzeige der Topology:
+<code java>
     /**
      * show the Topology Overview of the KStore
@@ Zeile 74: / Zeile 82: @@
             for (Topology.Component com :  part.getAll()) {
                 System.out.println(com.toString());
+            }
+            for ( StorageNode sn : topo.getSortedStorageNodes() ){
+                System.out.println("Read from "+ sn.getStorageNodeId() +" read :: "+sn.toString());
             }
@@ Zeile 87: / Zeile 98: @@
 </code>
+=== Beispiel für eine Anzeige des Status der einzelnen Nodes in einer CSV Sicht ===
+<code java>
+    public static CommandServiceAPI csi = null;
+    public static String adminNode = "localost";
+    public static int adminPort = 5000;
+    /**
+     *  init the Command API
+     */
+    public static void init(String nodeName, int RMIPort) {
+        try {
+            if (csi == null) {
+                csi = oracle.kv.impl.util.registry.RegistryUtils.getAdmin(nodeName, RMIPort);
+            }
+        } catch (Exception ex) {
+            System.out.println(ex.toString());
+        }
+    }
+    public static void showTopology() {
+        try {
+            if (csi == null) {
+                init(adminNode, adminPort);
+            }
+            // get the topo
+            Topology topo = csi.getTopology();
+            //register util
+            RegistryUtils regUtils = new RegistryUtils(topo);
+            // grep the status
+            ServiceStatus status = ServiceStatus.UNREACHABLE;
+            // For all Storage Nodes
+            StorageNodeStatus snStatus = null;
+            StorageNodeAgentAPI sna = null;
+            RepNodeStatus rnStatus = null;
+            RepNodeAdminAPI rna = null;
+            String repRole = "MASTER";
+            for (StorageNode sn : topo.getSortedStorageNodes()) {
+                sna = regUtils.getStorageNodeAgent(sn.getStorageNodeId());
+                snStatus = sna.ping();
+                status = snStatus.getServiceStatus();
+                System.out.printf("nosqlTopo=%s|%s|%s|null\n",sn.getStorageNodeId(),sn.toString(),status);
+                RepGroupMap snrepgrp = topo.getRepGroupMap();
+                for (RepGroup r : snrepgrp.getAll()) {
+                    for (RepNode rn2 : r.getRepNodes()) {
+                        rna = regUtils.getRepNodeAdmin(rn2.getResourceId());
+                        rnStatus = rna.ping();
+                        status = rnStatus.getServiceStatus();
+                        if (sn.getStorageNodeId().equals(rn2.getStorageNodeId())) {
+                            if (rnStatus.getReplicationState().isMaster()) {
+                                repRole = "MASTER";
+                            } else {
+                                repRole = "REPLICA";
+                            }
+                             System.out.printf("nosqlTopo=%s|%s|%s|%s\n",rn2.toString(),r.toString(),status,repRole);
+                        }
+                    }
+                }
+            }
+        } catch (Exception ex) {
+            System.out.println(ex.toString());
+        }
+</code>