Divide the MSB source codes into two repos

[msb/apigateway.git] / apiroute / apiroute-service / src / main / java / org / onap / msb / apiroute / wrapper / consulextend / HealthClient.java

diff --git a/apiroute/apiroute-service/src/main/java/org/onap/msb/apiroute/wrapper/consulextend/HealthClient.java b/apiroute/apiroute-service/src/main/java/org/onap/msb/apiroute/wrapper/consulextend/HealthClient.java
new file mode 100644 (file)
index 0000000..899a57a
--- /dev/null
+++ b/apiroute/apiroute-service/src/main/java/org/onap/msb/apiroute/wrapper/consulextend/HealthClient.java
@@ -0,0 +1,112 @@
+package org.onap.msb.apiroute.wrapper.consulextend;
+
+import java.util.List;
+
+import org.apache.http.HttpHost;
+import org.onap.msb.apiroute.wrapper.consulextend.async.ConsulResponseCallback;
+import org.onap.msb.apiroute.wrapper.consulextend.model.health.ServiceHealth;
+import org.onap.msb.apiroute.wrapper.consulextend.util.Http;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.fasterxml.jackson.core.type.TypeReference;
+import com.orbitz.consul.option.CatalogOptions;
+import com.orbitz.consul.option.QueryOptions;
+
+/**
+ * HTTP Client for /v1/health/ endpoints.
+ */
+public class HealthClient {
+       private final static Logger LOGGER = LoggerFactory
+                       .getLogger(HealthClient.class);
+
+       private static final TypeReference<List<ServiceHealth>> TYPE_SERVICE_HEALTH_LIST = new TypeReference<List<ServiceHealth>>() {
+       };
+
+       private static final String HEALTH_URI_10081 = "/api/health/v1";
+       private static final String HEALTH_URI_8500 = "/v1/health";
+       private static final String GET_HEALTH_SERVICE_URI = "/service";
+       
+//     private static final String GET_HEALTH_SERVICE_URI = "/v1/health/service";
+       
+//     private static final String GET_HEALTH_SERVICE_URI = "/api/health/v1/service";
+
+       private final static Http httpClient = Http.getInstance();
+
+       private HttpHost targetHost = null;
+       private String healthUri = HEALTH_URI_10081;
+
+       HealthClient(final HttpHost targetHost) {
+               this.targetHost = targetHost;
+               
+               if(targetHost.getPort() == 8500)
+               {
+                       healthUri = HEALTH_URI_8500;
+               }
+       }
+
+       /**
+        * Asynchronously retrieves the healthchecks for all healthy service
+        * instances in a given datacenter with
+        * {@link com.orbitz.consul.option.QueryOptions}.
+        * 
+        * GET /v1/health/service/{service}?dc={datacenter}&amp;passing
+        * 
+        * Experimental.
+        * 
+        * @param service
+        *            The service to query.
+        * @param catalogOptions
+        *            The catalog specific options to use.
+        * @param queryOptions
+        *            The Query Options to use.
+        * @param callback
+        *            Callback implemented by callee to handle results.
+        */
+       public void getHealthyServiceInstances(String service,
+                       CatalogOptions catalogOptions, QueryOptions queryOptions,
+                       ConsulResponseCallback<List<ServiceHealth>> callback) {
+               // prepare access path
+               String path = targetHost.toString() + healthUri + GET_HEALTH_SERVICE_URI + "/"+ service;
+               
+               String params = Http.optionsFrom(catalogOptions, queryOptions);
+               path = (params != null && !params.isEmpty()) ? path += "?"
+                               + params : path;  //query all nodes without filter for health
+
+               // async watch
+//             LOGGER.info("get health paasing service:" + path);
+               httpClient.asyncGetDelayHandle(path, TYPE_SERVICE_HEALTH_LIST, callback);
+       }
+
+       /**
+        * Asynchronously retrieves the healthchecks for all nodes in a given
+        * datacenter with {@link com.orbitz.consul.option.QueryOptions}.
+        * 
+        * GET /v1/health/service/{service}?dc={datacenter}
+        * 
+        * Experimental.
+        * 
+        * @param service
+        *            The service to query.
+        * @param catalogOptions
+        *            The catalog specific options to use.
+        * @param queryOptions
+        *            The Query Options to use.
+        * @param callback
+        *            Callback implemented by callee to handle results.
+        */
+       public void getAllServiceInstances(String service,
+                       CatalogOptions catalogOptions, QueryOptions queryOptions,
+                       ConsulResponseCallback<List<ServiceHealth>> callback) {
+
+               // prepare access path
+               String path = targetHost.toString() + healthUri + GET_HEALTH_SERVICE_URI + "/"+ service;
+               String params = Http.optionsFrom(catalogOptions, queryOptions);
+               path = (params != null && !params.isEmpty()) ? path += "?" + params
+                               : path;
+
+               // async watch
+//             LOGGER.debug("get service:" + path);
+               httpClient.asyncGetDelayHandle(path, TYPE_SERVICE_HEALTH_LIST, callback);
+       }
+}
\ No newline at end of file