[#2] Add api : /cluster/status

Author: WikiDru

src/main/java/org/code13k/heets/app/Cluster.java

@@ -5,11 +5,12 @@
 import com.hazelcast.config.NetworkConfig;
 import com.hazelcast.config.TcpIpConfig;
 import com.hazelcast.core.*;
+import com.hazelcast.nio.Address;
 import org.code13k.heets.config.AppConfig;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import java.util.ArrayList;
+import java.util.*;
 
 public class Cluster {
     // Logger
@@ -86,6 +87,27 @@ public HazelcastInstance getHazelcastInstance() {
         return mHazelcastInstance;
     }
 
+
+    /**
+     * Get all values
+     */
+    public Map<String, Object> values() {
+        HashMap<String, Object> result = new HashMap<>();
+
+        result.put("version", getClusterVersion());
+        result.put("count", getMemberCount());
+        result.put("info", getMemberInfo());
+
+        return result;
+    }
+
+    /**
+     * Get cluster version
+     */
+    public String getClusterVersion(){
+        return mHazelcastInstance.getCluster().getClusterVersion().toString();
+    }
+
     /**
      * Get clustered member count
      */
@@ -96,6 +118,23 @@ public int getMemberCount() {
             return 1;
         }
     }
+
+    /**
+     * Get clustered member info
+     */
+    public List<Map<String, String>> getMemberInfo(){
+        ArrayList<Map<String, String>> result = new ArrayList<>();
+        mHazelcastInstance.getCluster().getMembers().forEach(member -> {
+            HashMap<String, String> item = new HashMap<>();
+            Address memberAddress = member.getAddress();
+            item.put("version", member.getVersion().toString());
+            item.put("uuid", member.getUuid());
+            item.put("address", memberAddress.getHost()+":"+memberAddress.getPort());
+            result.add(item);
+        });
+        return result;
+    }
+
 }
 
 

src/main/java/org/code13k/heets/service/api/ApiHttpServer.java

@@ -8,6 +8,7 @@
 import io.vertx.ext.web.RoutingContext;
 import org.code13k.heets.config.AppConfig;
 import org.code13k.heets.service.api.controller.AppAPI;
+import org.code13k.heets.service.api.controller.ClusterAPI;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -20,6 +21,7 @@ public class ApiHttpServer extends AbstractVerticle {
 
     // Data
     private AppAPI mAppAPI = new AppAPI();
+    private ClusterAPI mClusterAPI = new ClusterAPI();
 
     /**
      * start()
@@ -38,6 +40,7 @@ public void start() throws Exception {
         // Routing
         Router router = Router.router(vertx);
         setAppRouter(router);
+        setClusterRouter(router);
 
         // Listen
         httpServer.requestHandler(router::accept).listen();
@@ -128,6 +131,21 @@ public void handle(Void event) {
         });
     }
 
+    /**
+     * Set cluster router
+     */
+    private void setClusterRouter(Router router) {
+        // GET /cluster/status
+        router.route().method(HttpMethod.GET).path("/cluster/status").handler(routingContext -> {
+            routingContext.request().endHandler(new Handler<Void>() {
+                @Override
+                public void handle(Void event) {
+                    responseHttpOK(routingContext, mClusterAPI.status());
+                }
+            });
+        });
+    }
+
     /**
      * Response HTTP 200 OK
      */

src/main/java/org/code13k/heets/service/api/controller/AppAPI.java

@@ -13,9 +13,6 @@
 import java.util.Map;
 
 public class AppAPI extends BasicAPI {
-    // Logger
-    private static final Logger mLogger = LoggerFactory.getLogger(AppAPI.class);
-
     /**
      * Environment
      */

src/main/java/org/code13k/heets/service/api/controller/ClusterAPI.java

@@ -0,0 +1,12 @@
+package org.code13k.heets.service.api.controller;
+
+import org.code13k.heets.app.Cluster;
+
+public class ClusterAPI extends BasicAPI {
+    /**
+     * Environment
+     */
+    public String status() {
+        return toResultJsonString(Cluster.getInstance().values());
+    }
+}