Health statistics

components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/beans/healthStatistics/AverageLoadAverageBean.java

@@ -0,0 +1,57 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.stratos.common.beans.healthStatistics;
+
+/*
+* This bean class may use to create the data transfer objects for Load Average data of clusters and members.
+* */
+public class AverageLoadAverageBean {
+
+    private static final long serialVersionUID = -7788619177798333712L;
+
+    private final String clusterId;
+    private final Long timeStamp;
+    private final Double memberAverageLoadAverage;
+    private final String memberId;
+
+    public AverageLoadAverageBean(String clusterId, Long timeStamp, Double memberAverageLoadAverage, String memberId) {
+        this.clusterId = clusterId;
+        this.timeStamp = timeStamp;
+        this.memberAverageLoadAverage = memberAverageLoadAverage;
+        this.memberId = memberId;
+    }
+
+    public String getClusterId() {
+        return clusterId;
+    }
+
+    public Double getMemberAverageLoadAverage() {
+        return memberAverageLoadAverage;
+    }
+
+    public Long getTimeStamp() {
+        return timeStamp;
+    }
+
+    public String getMemberId() {
+        return memberId;
+    }
+
+}

components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/beans/healthStatistics/AverageMemoryConsumptionBean.java

@@ -0,0 +1,58 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.stratos.common.beans.healthStatistics;
+
+/*
+* This bean class may use to create the data transfer objects for Average Memory data of clusters and members.
+* */
+public class AverageMemoryConsumptionBean {
+
+    private static final long serialVersionUID = -7788619177798333711L;
+
+    private final String clusterId;
+    private final Double memberAverageMemoryConsumption;
+    private final Long timeStamp;
+    private final String memberId;
+
+    public AverageMemoryConsumptionBean(final String clusterId,final Double memberAverageMemoryConsumption,final Long timeStamp,final String memberId) {
+        this.clusterId = clusterId;
+        this.memberAverageMemoryConsumption = memberAverageMemoryConsumption;
+        this.timeStamp = timeStamp;
+        this.memberId = memberId;
+    }
+
+    public String getClusterId() {
+        return clusterId;
+    }
+
+    public Double getMemberAverageMemoryConsumption() {
+        return memberAverageMemoryConsumption;
+    }
+
+    public Long getTimeStamp() {
+        return timeStamp;
+    }
+
+    public String getMemberId() {
+        return memberId;
+    }
+
+}
+

components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/beans/healthStatistics/InFlightRequestBean.java

@@ -0,0 +1,51 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+package org.apache.stratos.common.beans.healthStatistics;
+
+/*
+* This bean class may use to create the data transfer objects for Inflight request data of clusters.
+* */
+public class InFlightRequestBean {
+
+    private static final long serialVersionUID = -7788619177798333712L;
+
+    private final String clusterId;
+    private final Long timeStamp;
+    private final Double inFlightRequestCount;
+
+    public InFlightRequestBean(String clusterId, Long timeStamp, Double inFlightRequestCount) {
+        this.clusterId = clusterId;
+        this.timeStamp = timeStamp;
+        this.inFlightRequestCount = inFlightRequestCount;
+    }
+
+    public String getClusterId() {
+        return clusterId;
+    }
+
+    public Double getInFlightRequestCount() {
+        return inFlightRequestCount;
+    }
+
+    public Long getTimeStamp() {
+        return timeStamp;
+    }
+
+}

components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/wso2/cep/WSO2CEPHealthStatisticsPublisher.java

@@ -56,6 +56,7 @@ private static StreamDefinition createStreamDefinition() {
             payloadData.add(new Attribute("cluster_instance_id", AttributeType.STRING));
             payloadData.add(new Attribute("network_partition_id", AttributeType.STRING));
             payloadData.add(new Attribute("member_id", AttributeType.STRING));
+            payloadData.add(new Attribute("timeStamp", AttributeType.LONG));
             payloadData.add(new Attribute("partition_id", AttributeType.STRING));
             payloadData.add(new Attribute("health_description", AttributeType.STRING));
             payloadData.add(new Attribute("value", AttributeType.DOUBLE));
@@ -90,6 +91,7 @@ public void publish(String clusterId, String clusterInstanceId, String networkPa
         payload.add(clusterInstanceId);
         payload.add(networkPartitionId);
         payload.add(memberId);
+        payload.add(System.currentTimeMillis());
         payload.add(partitionId);
         payload.add(health);
         payload.add(value);

components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/wso2/cep/WSO2CEPInFlightRequestPublisher.java

@@ -53,6 +53,7 @@ private static StreamDefinition createStreamDefinition() {
             // Set payload definition
             payloadData.add(new Attribute("cluster_id", AttributeType.STRING));
             payloadData.add(new Attribute("cluster_instance_id", AttributeType.STRING));
+            payloadData.add(new Attribute("timeStamp", AttributeType.LONG));
             payloadData.add(new Attribute("network_partition_id", AttributeType.STRING));
             payloadData.add(new Attribute("in_flight_request_count", AttributeType.DOUBLE));
             streamDefinition.setPayloadData(payloadData);
@@ -76,6 +77,7 @@ public void publish(String clusterId, String clusterInstanceId, String networkPa
         List<Object> payload = new ArrayList<Object>();
         payload.add(clusterId);
         payload.add(clusterInstanceId);
+        payload.add(System.currentTimeMillis());
         payload.add(networkPartitionId);
         payload.add((double) inFlightRequestCount);
 

components/org.apache.stratos.manager.console/console/applications_form.jag

@@ -26,6 +26,7 @@ var log = new Log("apachestratos.applications_form"),
         error = [],
         list_data,
         caramel = require('caramel'),
+        config = require('/config/console.json'),
         context = caramel.configs().context,
         menuJson = require('/controllers/menu/menu.json'),
         util = require('/controllers/rest/rest_calls.jag'),
@@ -49,7 +50,8 @@ if (!elements) {
         var applicationName = elements.applicationId;
 
         //get application json
-        applicationJSON = util.RESTCalls.getApplicationJSON(applicationName);
+        applicationJSONapplicationJSON = util.RESTCalls.getApplicationJSON(applicationName);
+
         var applicationAlias = applicationJSON.alias;
 
         if(elements.action == 'view'){
@@ -90,6 +92,7 @@ if (!elements) {
 
 }
 
+var healthStatisticEnable=config.healthStatistics.UI_enable;
 
 var formtype = elements.formtype;
 
@@ -109,6 +112,7 @@ switch (formtype) {
 var caramelData = {
     breadcrumbPathLevelOne: breadcrumbPathLevelOne,
     breadcrumbPathLevelTwo: '',
+    healthStatisticEnable:healthStatisticEnable,
     left_menu: leftMenu,
     isForm: isForm,
     isEdit: isEdit,

components/org.apache.stratos.manager.console/console/config/console.json

@@ -1,5 +1,8 @@
 {
     "backendServerConfiguration": {
         "url": "%https.host%/api/v4.1"
+    },
+    "healthStatistics": {
+        "UI_enable": "false"
     }
 }

components/org.apache.stratos.manager.console/console/controllers/healthStatistics/healthStatistics_getrequest.jag

@@ -0,0 +1,117 @@
+<%
+/*
+ *
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ *
+ */
+    var log = new Log("apachestratos.configure_request"),
+            util = require('/controllers/rest/rest_calls.jag'),
+            formtype = request.getParameter('formtype'),
+            ChartType = request.getParameter('chartType'),
+            Duration = request.getParameter('duration'),
+            IdValue = request.getParameter('idValue');
+
+    var formSubmit;
+    var DurationVal;
+
+    //creatingTimeObjects
+    var startTime = new Date();
+    var endTime = new Date();
+
+    //add login validator for pages
+    include('/controllers/login/validator.jag');
+
+    //checking the interval for the required data to check
+    if( "30Min" != Duration){
+
+    switch (Duration) {
+
+        case "1Hour":
+            DurationVal = 1;
+            break;
+        case "1Day":
+            DurationVal = 24;
+            break;
+        case "1Week":
+            DurationVal = 168;
+            break;
+        case "1Month":
+            DurationVal = 672;
+            break;
+    }
+
+    //substratcting hour from current time
+    startTime.setHours(endTime.getHours() - DurationVal);
+
+    } else {
+
+    //substratcting hour from current time
+    startTime.setMinutes(endTime.getMinutes() - 30);
+
+    }
+
+    //switch to trigger the rest call when needs
+    try {
+        switch (formtype) {
+
+            case "MemoryConsumption":
+
+                if("Cluster" == ChartType){
+
+                    formSubmit = util.RESTCalls.getClusterMemoryAverageDetails(IdValue, startTime.getTime(),endTime.getTime());
+                    break;
+                }
+                else{
+                    formSubmit = util.RESTCalls.getMemberMemoryAvrageDetails(IdValue, startTime.getTime(),endTime.getTime());
+                    break;
+                }
+
+            case "LoadAverage":
+
+                if("Cluster" == ChartType){
+                    formSubmit = util.RESTCalls.getClusterLoadAverageDetails(IdValue, startTime.getTime(),endTime.getTime());
+                    break;
+                }
+                else{
+                    formSubmit = util.RESTCalls.getMemberLoadAverageDetails(IdValue, startTime.getTime(),endTime.getTime());
+                    break;
+                }
+
+            case "InFlight":
+                formSubmit = util.RESTCalls.getFlightRequestDetails(IdValue, startTime.getTime(),endTime.getTime());
+                break;
+
+            default:
+                session.put("deploy-status", { "message": "Sorry Endpoint Error", "status": "error" });
+        }
+
+    //vaidating the response and return
+        if (formSubmit == undefined)
+        {
+        print({"status": 'error', "message": "No Data found!"});
+
+        } else {
+            print(formSubmit);
+        }
+
+    } catch (e) {
+        log.warn(e);
+        print({"status": 'error', "message": e.toString()});
+    }
+
+%>