Repository: stratos Updated Branches: refs/heads/master 91b991909 -> fdd2b14c4
http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/GadgetScalingDetails/artifact.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/GadgetScalingDetails/artifact.xml b/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/GadgetScalingDetails/artifact.xml new file mode 100644 index 0000000..2f03d0b --- /dev/null +++ b/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/GadgetScalingDetails/artifact.xml @@ -0,0 +1,24 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + + 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. + +--> +<artifact name="GadgetScalingDetails" version="1.0.0" type="dashboards/gadget" serverRole="DataAnalyticsServer"> + <file>Scaling_Details</file> +</artifact> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsInFlightRequest/artifact.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsInFlightRequest/artifact.xml b/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsInFlightRequest/artifact.xml new file mode 100644 index 0000000..4b64f10 --- /dev/null +++ b/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsInFlightRequest/artifact.xml @@ -0,0 +1,24 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + + 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. + +--> +<artifact name="SparkscriptsInFlightRequest" version="1.0.0" type="analytics/spark" serverRole="DataAnalyticsServer"> + <file>in_flight_request.xml</file> +</artifact> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsInFlightRequest/in_flight_request.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsInFlightRequest/in_flight_request.xml b/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsInFlightRequest/in_flight_request.xml new file mode 100644 index 0000000..70fb660 --- /dev/null +++ b/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsInFlightRequest/in_flight_request.xml @@ -0,0 +1,35 @@ +<?xml version="1.0" encoding="UTF-8" standalone="yes"?> +<!-- + + 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. + +--> +<Analytics> + <Name>in_flight_request</Name> + <Script> + CREATE TEMPORARY TABLE average_in_flight_requests + USING CarbonAnalytics + OPTIONS (tableName "AVERAGE_IN_FLIGHT_REQUESTS"); + + create temporary table average_in_flight_requests_new + using CarbonJDBC options (dataSource "WSO2_ANALYTICS_EVENT_STORE_DB", tableName "AVERAGE_IN_FLIGHT_REQUESTS"); + + INSERT OVERWRITE TABLE average_in_flight_requests_new select * from average_in_flight_requests; + </Script> + <CronExpression>0/15 * * * * ?</CronExpression> +</Analytics> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsLoadAverage/artifact.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsLoadAverage/artifact.xml b/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsLoadAverage/artifact.xml new file mode 100644 index 0000000..8420890 --- /dev/null +++ b/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsLoadAverage/artifact.xml @@ -0,0 +1,24 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + + 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. + +--> +<artifact name="SparkscriptsLoadAverage" version="1.0.0" type="analytics/spark" serverRole="DataAnalyticsServer"> + <file>load_average.xml</file> +</artifact> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsLoadAverage/load_average.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsLoadAverage/load_average.xml b/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsLoadAverage/load_average.xml new file mode 100644 index 0000000..3dcc196 --- /dev/null +++ b/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsLoadAverage/load_average.xml @@ -0,0 +1,46 @@ +<?xml version="1.0" encoding="UTF-8" standalone="yes"?> +<!-- + + 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. + +--> +<Analytics> + <Name>load_average</Name> + <Script> + CREATE TEMPORARY TABLE average_load_average_stats + USING CarbonAnalytics + OPTIONS (tableName "AVERAGE_LOAD_AVERAGE_STATS"); + + create temporary table average_load_average_stats_new + using CarbonJDBC options (dataSource "WSO2_ANALYTICS_EVENT_STORE_DB", tableName "AVERAGE_LOAD_AVERAGE_STATS"); + + INSERT OVERWRITE TABLE average_load_average_stats_new select timestamp, cluster_id, cluster_instance_id, + network_partition_id, average_load_average from average_load_average_stats; + + CREATE TEMPORARY TABLE member_average_load_average_stats + USING CarbonAnalytics + OPTIONS (tableName "MEMBER_AVERAGE_LOAD_AVERAGE_STATS"); + + create temporary table member_average_load_average_stats_new + using CarbonJDBC options (dataSource "WSO2_ANALYTICS_EVENT_STORE_DB", tableName "MEMBER_AVERAGE_LOAD_AVERAGE_STATS"); + + INSERT OVERWRITE TABLE member_average_load_average_stats_new select timestamp, member_id, cluster_id, cluster_instance_id, + network_partition_id, member_average_load_average from member_average_load_average_stats; + </Script> + <CronExpression>0/15 * * * * ?</CronExpression> +</Analytics> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsMemoryUsage/artifact.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsMemoryUsage/artifact.xml b/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsMemoryUsage/artifact.xml new file mode 100644 index 0000000..972449f --- /dev/null +++ b/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsMemoryUsage/artifact.xml @@ -0,0 +1,24 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + + 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. + +--> +<artifact name="SparkscriptsMemoryUsage" version="1.0.0" type="analytics/spark" serverRole="DataAnalyticsServer"> + <file>memory_usage.xml</file> +</artifact> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsMemoryUsage/memory_usage.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsMemoryUsage/memory_usage.xml b/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsMemoryUsage/memory_usage.xml new file mode 100644 index 0000000..b93f503 --- /dev/null +++ b/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsMemoryUsage/memory_usage.xml @@ -0,0 +1,46 @@ +<?xml version="1.0" encoding="UTF-8" standalone="yes"?> +<!-- + + 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. + +--> +<Analytics> + <Name>memory_usage</Name> + <Script> + CREATE TEMPORARY TABLE average_memory_consumption_stats + USING CarbonAnalytics + OPTIONS (tableName "AVERAGE_MEMORY_CONSUMPTION_STATS"); + + create temporary table average_memory_consumption_stats_new + using CarbonJDBC options (dataSource "WSO2_ANALYTICS_EVENT_STORE_DB", tableName "AVERAGE_MEMORY_CONSUMPTION_STATS"); + + INSERT OVERWRITE TABLE average_memory_consumption_stats_new select timestamp, cluster_id, cluster_instance_id, + network_partition_id, average_memory_consumption from average_memory_consumption_stats; + + CREATE TEMPORARY TABLE member_average_memory_consumption_stats + USING CarbonAnalytics + OPTIONS (tableName "MEMBER_AVERAGE_MEMORY_CONSUMPTION_STATS"); + + create temporary table member_average_memory_consumption_stats_new + using CarbonJDBC options (dataSource "WSO2_ANALYTICS_EVENT_STORE_DB", tableName "MEMBER_AVERAGE_MEMORY_CONSUMPTION_STATS"); + + INSERT OVERWRITE TABLE member_average_memory_consumption_stats_new select timestamp, member_id, cluster_id, cluster_instance_id, + network_partition_id, member_average_memory_consumption from member_average_memory_consumption_stats; + </Script> + <CronExpression>0/15 * * * * ?</CronExpression> +</Analytics> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsScalingDecision/artifact.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsScalingDecision/artifact.xml b/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsScalingDecision/artifact.xml new file mode 100644 index 0000000..ef13f69 --- /dev/null +++ b/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsScalingDecision/artifact.xml @@ -0,0 +1,24 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + + 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. + +--> +<artifact name="SparkscriptsScalingDecision" version="1.0.0" type="analytics/spark" serverRole="DataAnalyticsServer"> + <file>scaling_decision.xml</file> +</artifact> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsScalingDecision/scaling_decision.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsScalingDecision/scaling_decision.xml b/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsScalingDecision/scaling_decision.xml new file mode 100644 index 0000000..c7f9730 --- /dev/null +++ b/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/SparkscriptsScalingDecision/scaling_decision.xml @@ -0,0 +1,35 @@ +<?xml version="1.0" encoding="UTF-8" standalone="yes"?> +<!-- + + 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. + +--> +<Analytics> + <Name>scaling_decision</Name> + <Script> + CREATE TEMPORARY TABLE scalingdecision + USING CarbonAnalytics + OPTIONS (tableName "SCALING_DECISION"); + + create temporary table scaling_details + using CarbonJDBC options (dataSource "WSO2_ANALYTICS_EVENT_STORE_DB", tableName "SCALING_DETAILS"); + + INSERT OVERWRITE TABLE scaling_details select * from scalingdecision; + </Script> + <CronExpression>0/15 * * * * ?</CronExpression> +</Analytics> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/artifacts.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/artifacts.xml b/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/artifacts.xml new file mode 100644 index 0000000..fbdd8f7 --- /dev/null +++ b/extensions/das/modules/artifacts/monitoring-dashboard/capps/stratos-monitoring-service/artifacts.xml @@ -0,0 +1,74 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + + 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. + +--> +<artifacts> + <artifact name="stratos-monitoring-service" version="1.0.0" type="carbon/application"> + <dependency artifact="EventstreamAverageInFlightRequest" version="1.0.0" include="true" + serverRole="DataAnalyticsServer"/> + <dependency artifact="EventstreamAverageLoadAvergaeStats" version="1.0.0" include="true" + serverRole="DataAnalyticsServer"/> + <dependency artifact="EventstreamAverageMemoryConsumptionStats" version="1.0.0" include="true" + serverRole="DataAnalyticsServer"/> + <dependency artifact="EventstreamMemberAverageLoadAverageStats" version="1.0.0" include="true" + serverRole="DataAnalyticsServer"/> + <dependency artifact="EventstreamMemberAverageMemoryConsumptionStats" version="1.0.0" include="true" + serverRole="DataAnalyticsServer"/> + <dependency artifact="EventstreamScalingDecision" version="1.0.0" include="true" + serverRole="DataAnalyticsServer"/> + <dependency artifact="EventstoreAverageInFlightRequest" version="1.0.0" include="true" + serverRole="DataAnalyticsServer"/> + <dependency artifact="EventstoreAverageLoadAverageStats" version="1.0.0" include="true" + serverRole="DataAnalyticsServer"/> + <dependency artifact="EventstoreAverageMemoryConsumptionStats" version="1.0.0" include="true" + serverRole="DataAnalyticsServer"/> + <dependency artifact="EventstoreMemberAverageLoadAvaerageStats" version="1.0.0" + include="true" serverRole="DataAnalyticsServer"/> + <dependency artifact="EventstoreMemberAverageMemoryConsumptionStats" version="1.0.0" include="true" + serverRole="DataAnalyticsServer"/> + <dependency artifact="EventstoreScalingDecision" version="1.0.0" include="true" + serverRole="DataAnalyticsServer"/> + <dependency artifact="EventreceiverAverageInFlightRequest" version="1.0.0" include="true" + serverRole="DataAnalyticsServer"/> + <dependency artifact="EventreceiverAverageLoadAverageStats" version="1.0.0" include="true" + serverRole="DataAnalyticsServer"/> + <dependency artifact="EventreceiverAverageMemoryConsumptionStats" version="1.0.0" include="true" + serverRole="DataAnalyticsServer"/> + <dependency artifact="EventreceiverMemberAverageLoadAverageStats" version="1.0.0" include="true" + serverRole="DataAnalyticsServer"/> + <dependency artifact="EventreceiverMemberAverageMemoryConsumptionStats" version="1.0.0" include="true" + serverRole="DataAnalyticsServer"/> + <dependency artifact="EventreceiverScalingDecision" version="1.0.0" include="true" + serverRole="DataAnalyticsServer"/> + <dependency artifact="SparkscriptsInFlightRequest" version="1.0.0" include="true" + serverRole="DataAnalyticsServer"/> + <dependency artifact="SparkscriptsLoadAverage" version="1.0.0" include="true" serverRole="DataAnalyticsServer"/> + <dependency artifact="SparkscriptsMemoryUsage" version="1.0.0" include="true" serverRole="DataAnalyticsServer"/> + <dependency artifact="SparkscriptsScalingDecision" version="1.0.0" include="true" + serverRole="DataAnalyticsServer"/> + <dependency artifact="GadgetHealthStatsFilter" version="1.0.0" include="true" serverRole="DataAnalyticsServer"/> + <dependency artifact="GadgetInFlightRequest" version="1.0.0" include="true" serverRole="DataAnalyticsServer"/> + <dependency artifact="GadgetLoadAverage" version="1.0.0" include="true" serverRole="DataAnalyticsServer"/> + <dependency artifact="GadgetMemoryUsage" version="1.0.0" include="true" serverRole="DataAnalyticsServer"/> + <dependency artifact="GadgetScalingDetails" version="1.0.0" include="true" + serverRole="DataAnalyticsServer"/> + <dependency artifact="Dashboard" version="1.0.0" include="true" serverRole="DataAnalyticsServer"/> + </artifact> +</artifacts> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/health-stats-clusters.jag ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/health-stats-clusters.jag b/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/health-stats-clusters.jag new file mode 100644 index 0000000..767be3a --- /dev/null +++ b/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/health-stats-clusters.jag @@ -0,0 +1,42 @@ +<% +/* + * 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. + * + */ +include("monitoring-authentication.jag"); + +(function () { + + var db = new Database("WSO2_ANALYTICS_EVENT_STORE_DB"); + + try { + var clusterInstanceId = request.getParameter('clusterInstanceId'); + var result = db.query("SELECT DISTINCT ClusterId FROM AVERAGE_MEMORY_CONSUMPTION_STATS"); + + if (result != null) { + print(result); + } + } + catch (e) { + print(e.toString()); + } + finally { + db.close(); + } +}()); +%> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/health-stats-members.jag ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/health-stats-members.jag b/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/health-stats-members.jag new file mode 100644 index 0000000..c8cb711 --- /dev/null +++ b/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/health-stats-members.jag @@ -0,0 +1,42 @@ +<% +/* + * 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. + * + */ +include("monitoring-authentication.jag"); + +(function () { + + var db = new Database("WSO2_ANALYTICS_EVENT_STORE_DB"); + + try { + var clusterId = request.getParameter('clusterId'); + var result = db.query("SELECT DISTINCT MemberId FROM MEMBER_AVERAGE_MEMORY_CONSUMPTION_STATS WHERE ClusterId=?", clusterId); + + if (result != null) { + print(result); + } + } + catch (e) { + print(e.toString()); + } + finally { + db.close(); + } +}()); +%> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/in-flight-request.jag ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/in-flight-request.jag b/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/in-flight-request.jag new file mode 100644 index 0000000..9015b1e --- /dev/null +++ b/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/in-flight-request.jag @@ -0,0 +1,84 @@ +<% +/* + * 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. + * + */ +include("monitoring-authentication.jag"); + +(function () { + var log = new Log(); + + var TIME_INTERVAL_1 = '30 Min'; + var TIME_INTERVAL_2 = '1 Hour'; + var TIME_INTERVAL_3 = '1 Day'; + var TIME_INTERVAL_4 = '1 Week'; + var TIME_INTERVAL_5 = '1 Month'; + + var content = request.getContent(); + var contentAsString = null; + if (content != '' && content != null) { + contentAsString = stringify(content); + if (log.isDebugEnabled()) { + log.debug("Value of content: " + contentAsString); + } + } + + var db = new Database("WSO2_ANALYTICS_EVENT_STORE_DB"); + + try { + var result; + + var timeInterval = request.getParameter("time"); + var interval = 1800000; + var x_axis_interval; + var time_format; + if (timeInterval === TIME_INTERVAL_1) { + interval = 1800000; + x_axis_interval = 60; + time_format = '%h:%i'; + } else if (timeInterval === TIME_INTERVAL_2) { + interval = 3600000; + x_axis_interval = 120; + time_format = '%h:%i'; + } else if (timeInterval === TIME_INTERVAL_3) { + interval = 86400000; + x_axis_interval = 2880; + time_format = '%Y:%m:%d %h:%i'; + } else if (timeInterval === TIME_INTERVAL_4) { + interval = 604800000; + x_axis_interval = 20160; + time_format = '%Y:%m:%d %h:%i'; + } else if (timeInterval === TIME_INTERVAL_5) { + interval = 2419200000; + x_axis_interval = 80640; + time_format = '%Y:%m:%d'; + } + + var clusterId = request.getParameter("clusterId"); + result = db.query("SELECT FROM_UNIXTIME(CEILING( Time/('" + x_axis_interval + "'*1000)) *'" + x_axis_interval + "', '" + time_format + "') AS Time, AVG(Count) AS Count FROM AVERAGE_IN_FLIGHT_REQUESTS WHERE ClusterId=? AND Time > ROUND(UNIX_TIMESTAMP(CURTIME(4)) * 1000-'" + interval + "' ) AND Time <= ROUND(UNIX_TIMESTAMP(CURTIME(4)) * 1000) GROUP BY FROM_UNIXTIME( CEILING( Time/('" + x_axis_interval + "'*1000)) *'"+x_axis_interval+"', '%Y:%m:%d %h:%i'), ClusterId", clusterId); + print(result); + + } + catch (e) { + print(e.toString()); + } + finally { + db.close(); + } +}()); +%> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/load-average.jag ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/load-average.jag b/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/load-average.jag new file mode 100644 index 0000000..ce436ae --- /dev/null +++ b/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/load-average.jag @@ -0,0 +1,91 @@ +<% +/* + * 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. + * + */ +include("monitoring-authentication.jag"); + +(function () { + var log = new Log(); + + var TIME_INTERVAL_1 = '30 Min'; + var TIME_INTERVAL_2 = '1 Hour'; + var TIME_INTERVAL_3 = '1 Day'; + var TIME_INTERVAL_4 = '1 Week'; + var TIME_INTERVAL_5 = '1 Month'; + var ALL_MEMBERS = 'All Members'; + + var content = request.getContent(); + var contentAsString = null; + if (content != '' && content != null) { + contentAsString = stringify(content); + if (log.isDebugEnabled()) { + log.debug("Value of content: " + contentAsString); + } + } + + var db = new Database("WSO2_ANALYTICS_EVENT_STORE_DB"); + + try { + var result; + + var timeInterval = request.getParameter("time"); + var interval = 1800000; + var x_axis_interval; + var time_format; + if (timeInterval === TIME_INTERVAL_1) { + interval = 1800000; + x_axis_interval = 60; + time_format = '%h:%i'; + } else if (timeInterval === TIME_INTERVAL_2) { + interval = 3600000; + x_axis_interval = 120; + time_format = '%h:%i'; + } else if (timeInterval === TIME_INTERVAL_3) { + interval = 86400000; + x_axis_interval = 2880; + time_format = '%Y:%m:%d %h:%i'; + } else if (timeInterval === TIME_INTERVAL_4) { + interval = 604800000; + x_axis_interval = 20160; + time_format = '%Y:%m:%d %h:%i'; + } else if (timeInterval === TIME_INTERVAL_5) { + interval = 2419200000; + x_axis_interval = 80640; + time_format = '%Y:%m:%d'; + } + + var clusterId = request.getParameter("clusterId"); + var memberId = request.getParameter("memberId"); + + if (memberId == ALL_MEMBERS) { + result = db.query("SELECT FROM_UNIXTIME(CEILING( Time/('" + x_axis_interval + "'*1000)) *'" + x_axis_interval + "', '" + time_format + "') AS Time, AVG(Value) AS Value FROM AVERAGE_LOAD_AVERAGE_STATS WHERE ClusterId=? AND Time > ROUND(UNIX_TIMESTAMP(CURTIME(4)) * 1000-'" + interval + "' ) AND Time <= ROUND(UNIX_TIMESTAMP(CURTIME(4)) * 1000) GROUP BY FROM_UNIXTIME( CEILING( Time/('" + x_axis_interval + "'*1000)) *'"+x_axis_interval+"', '%Y:%m:%d %h:%i'), ClusterId", clusterId); + }else{ + result = db.query("SELECT FROM_UNIXTIME(CEILING( Time/('" + x_axis_interval + "'*1000)) *'" + x_axis_interval + "', '" + time_format + "') AS Time, AVG(Value) AS Value FROM MEMBER_AVERAGE_LOAD_AVERAGE_STATS WHERE ClusterId=? AND MemberId=? AND Time > ROUND(UNIX_TIMESTAMP(CURTIME(4)) * 1000-'" + interval + "' ) AND Time <= ROUND(UNIX_TIMESTAMP(CURTIME(4)) * 1000) GROUP BY FROM_UNIXTIME( CEILING( Time/('" + x_axis_interval + "'*1000)) *'"+x_axis_interval+"', '%Y:%m:%d %h:%i'), ClusterId, MemberId", clusterId, memberId); + } + print(result); + + } + catch (e) { + print(e.toString()); + } + finally { + db.close(); + } +}()); +%> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/memory-usage.jag ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/memory-usage.jag b/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/memory-usage.jag new file mode 100644 index 0000000..54d66d4 --- /dev/null +++ b/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/memory-usage.jag @@ -0,0 +1,91 @@ +<% +/* + * 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. + * + */ +include("monitoring-authentication.jag"); + +(function () { + var log = new Log(); + + var TIME_INTERVAL_1 = '30 Min'; + var TIME_INTERVAL_2 = '1 Hour'; + var TIME_INTERVAL_3 = '1 Day'; + var TIME_INTERVAL_4 = '1 Week'; + var TIME_INTERVAL_5 = '1 Month'; + var ALL_MEMBERS = 'All Members'; + + var content = request.getContent(); + var contentAsString = null; + if (content != '' && content != null) { + contentAsString = stringify(content); + if (log.isDebugEnabled()) { + log.debug("Value of content: " + contentAsString); + } + } + + var db = new Database("WSO2_ANALYTICS_EVENT_STORE_DB"); + + try { + var result; + + var timeInterval = request.getParameter("time"); + var interval = 1800000; + var x_axis_interval; + var time_format; + if (timeInterval === TIME_INTERVAL_1) { + interval = 1800000; + x_axis_interval = 60; + time_format = '%h:%i'; + } else if (timeInterval === TIME_INTERVAL_2) { + interval = 3600000; + x_axis_interval = 120; + time_format = '%h:%i'; + } else if (timeInterval === TIME_INTERVAL_3) { + interval = 86400000; + x_axis_interval = 2880; + time_format = '%Y:%m:%d %h:%i'; + } else if (timeInterval === TIME_INTERVAL_4) { + interval = 604800000; + x_axis_interval = 20160; + time_format = '%Y:%m:%d %h:%i'; + } else if (timeInterval === TIME_INTERVAL_5) { + interval = 2419200000; + x_axis_interval = 80640; + time_format = '%Y:%m:%d'; + } + + var clusterId = request.getParameter("clusterId"); + var memberId = request.getParameter("memberId"); + + if (memberId == ALL_MEMBERS) { + result = db.query("SELECT FROM_UNIXTIME(CEILING( Time/('" + x_axis_interval + "'*1000)) *'" + x_axis_interval + "', '" + time_format + "') AS Time, AVG(Value) AS Value FROM AVERAGE_MEMORY_CONSUMPTION_STATS WHERE ClusterId=? AND Time > ROUND(UNIX_TIMESTAMP(CURTIME(4)) * 1000-'" + interval + "' ) AND Time <= ROUND(UNIX_TIMESTAMP(CURTIME(4)) * 1000) GROUP BY FROM_UNIXTIME( CEILING( Time/('" + x_axis_interval + "'*1000)) *'"+x_axis_interval+"', '%Y:%m:%d %h:%i'), ClusterId", clusterId); + } else { + result = db.query("SELECT FROM_UNIXTIME(CEILING( Time/('" + x_axis_interval + "'*1000)) *'" + x_axis_interval + "', '" + time_format + "') AS Time, AVG(Value) AS Value FROM MEMBER_AVERAGE_MEMORY_CONSUMPTION_STATS WHERE ClusterId=? AND MemberId=? AND Time > ROUND(UNIX_TIMESTAMP(CURTIME(4)) * 1000-'" + interval + "' ) AND Time <= ROUND(UNIX_TIMESTAMP(CURTIME(4)) * 1000) GROUP BY FROM_UNIXTIME( CEILING( Time/('" + x_axis_interval + "'*1000)) *'"+x_axis_interval+"', '%Y:%m:%d %h:%i'), ClusterId, MemberId", clusterId, memberId); + } + print(result); + + } + catch (e) { + print(e.toString()); + } + finally { + db.close(); + } +}()); +%> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/monitoring-authentication.jag ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/monitoring-authentication.jag b/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/monitoring-authentication.jag new file mode 100644 index 0000000..dd2448c --- /dev/null +++ b/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/monitoring-authentication.jag @@ -0,0 +1,74 @@ +<% +/* + * 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. + * + */ +(function () { + var log = new Log(); + + var HTTPS_TRANSPORT = "https"; + var AUTHORIZATION_HEADER = "Authorization"; + var ANALYTICS_SERVICE = "/services/AnalyticsWebService"; + var AUTHENTICATION_SERVICE = "/services/AuthenticationAdmin"; + var AUTH_TOKEN = "authToken"; + var LOCALHOST = "localhost"; + var HTTP_USER_NOT_AUTHENTICATED = 403; + + var carbon = require('carbon'); + var configs = require('/configs/designer.json'); + var HTTPConstants = Packages.org.apache.axis2.transport.http.HTTPConstants; + var AnalyticsWebServiceStub = Packages.org.wso2.carbon.analytics.webservice.stub.AnalyticsWebServiceStub; + var AuthenticationAdminStub = Packages.org.wso2.carbon.authenticator.stub.AuthenticationAdminStub; + + var analyticsWSUrl = carbon.server.address(HTTPS_TRANSPORT) + ANALYTICS_SERVICE; + var authenticationWSUrl = carbon.server.address(HTTPS_TRANSPORT) + AUTHENTICATION_SERVICE; + var analyticsStub; + try { + analyticsStub = new AnalyticsWebServiceStub(analyticsWSUrl); + } catch (e) { + if (log.isDebugEnabled()) { + log.debug("Unable to instantiate AnalyticsWebServiceStub instance. This could be a CEP server. Returning"); + } + return; + } + var serviceClient = analyticsStub._getServiceClient(); + var options = serviceClient.getOptions(); + options.setManageSession(true); + + var authParam = request.getHeader(AUTHORIZATION_HEADER); + if (authParam != null) { + credentials = JSUtils.authenticate(authParam); + authenticationAdminStub = new AuthenticationAdminStub(authenticationWSUrl); + authenticationAdminStub.login(credentials[0], credentials[1], LOCALHOST); + var serviceContext = authenticationAdminStub._getServiceClient().getLastOperationContext() + .getServiceContext(); + var sessionCookie = serviceContext.getProperty(HTTPConstants.COOKIE_STRING); + options.setProperty(HTTPConstants.COOKIE_STRING, sessionCookie); + } else { + var token = session.get(AUTH_TOKEN); + if (token != null) { + options.setProperty(HTTPConstants.COOKIE_STRING, token); + } else { + log.error("user is not authenticated!"); + response.status = HTTP_USER_NOT_AUTHENTICATED; + print('{ "status": "Failed", "message": "User is not authenticated." }'); + return; + } + } +}); +%> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/scaling-details.jag ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/scaling-details.jag b/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/scaling-details.jag new file mode 100644 index 0000000..c74e3d3 --- /dev/null +++ b/extensions/das/modules/artifacts/monitoring-dashboard/jaggery-files/scaling-details.jag @@ -0,0 +1,73 @@ +<% +/* + * 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. + * + */ +include("monitoring-authentication.jag"); + +(function () { + var log = new Log(); + + var TIME_INTERVAL_1 = '30 Min'; + var TIME_INTERVAL_2 = '1 Hour'; + var TIME_INTERVAL_3 = '1 Day'; + var TIME_INTERVAL_4 = '1 Week'; + var TIME_INTERVAL_5 = '1 Month'; + var ALL_CLUSTERS = 'All Clusters'; + + var content = request.getContent(); + var contentAsString = null; + if (content != '' && content != null) { + contentAsString = stringify(content); + if (log.isDebugEnabled()) { + log.debug("Value of content: " + contentAsString); + } + } + + var db = new Database("WSO2_ANALYTICS_EVENT_STORE_DB"); + + try { + var result; + + var timeInterval = request.getParameter("time"); + var interval = 1800000; + + if (timeInterval === TIME_INTERVAL_1) { + interval = 1800000; + } else if (timeInterval === TIME_INTERVAL_2) { + interval = 3600000; + } else if (timeInterval === TIME_INTERVAL_3) { + interval = 86400000; + } else if (timeInterval === TIME_INTERVAL_4) { + interval = 604800000; + } else if (timeInterval === TIME_INTERVAL_5) { + interval = 2419200000; + } + + var clusterId = request.getParameter("clusterId"); + result = db.query("SELECT FROM_UNIXTIME(CEILING( Time/1000 ), '%Y:%m:%d %h:%i') AS Time, ClusterId, MinInstanceCount, MaxInstanceCount, RIFPredicted, RIFThreshold, RIFRequiredInstances, MCPredicted, MCThreshold, MCRequiredInstances, LAPredicted, LAThreshold, LARequiredInstances, RequiredInstanceCount, ActiveInstanceCount, AdditionalInstanceCount, ScalingReason FROM SCALING_DETAILS WHERE ClusterId= ? AND Time > ROUND(UNIX_TIMESTAMP(CURTIME(4)) * 1000-'" + interval + "' ) AND Time <= ROUND(UNIX_TIMESTAMP(CURTIME(4)) * 1000)", clusterId); + print(result); + } + catch (e) { + print(e.toString()); + } + finally { + db.close(); + } +}()); +%> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/monitoring-dashboard/monitoring-mysqlscript.sql ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/monitoring-dashboard/monitoring-mysqlscript.sql b/extensions/das/modules/artifacts/monitoring-dashboard/monitoring-mysqlscript.sql new file mode 100644 index 0000000..0155fa7 --- /dev/null +++ b/extensions/das/modules/artifacts/monitoring-dashboard/monitoring-mysqlscript.sql @@ -0,0 +1,28 @@ +/* + * 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. + * + */ +CREATE DATABASE IF NOT EXISTS ANALYTICS_FS_DB; +CREATE DATABASE IF NOT EXISTS ANALYTICS_EVENT_STORE; +CREATE DATABASE IF NOT EXISTS ANALYTICS_PROCESSED_DATA_STORE; +CREATE TABLE ANALYTICS_EVENT_STORE.AVERAGE_MEMORY_CONSUMPTION_STATS(Time long, ClusterId VARCHAR(150), ClusterInstanceId VARCHAR(150), NetworkPartitionId VARCHAR(150), Value DOUBLE); +CREATE TABLE ANALYTICS_EVENT_STORE.MEMBER_AVERAGE_MEMORY_CONSUMPTION_STATS(Time long, MemberId VARCHAR(150), ClusterId VARCHAR(150), ClusterInstanceId VARCHAR(150), NetworkPartitionId VARCHAR(150), Value DOUBLE); +CREATE TABLE ANALYTICS_EVENT_STORE.AVERAGE_LOAD_AVERAGE_STATS(Time long, ClusterId VARCHAR(150), ClusterInstanceId VARCHAR(150), NetworkPartitionId VARCHAR(150), Value DOUBLE); +CREATE TABLE ANALYTICS_EVENT_STORE.MEMBER_AVERAGE_LOAD_AVERAGE_STATS(Time long, MemberId VARCHAR(150), ClusterId VARCHAR(150), ClusterInstanceId VARCHAR(150), NetworkPartitionId VARCHAR(150), Value DOUBLE); +CREATE TABLE ANALYTICS_EVENT_STORE.AVERAGE_IN_FLIGHT_REQUESTS(Time long, ClusterId VARCHAR(150), ClusterInstanceId VARCHAR(150), NetworkPartitionId VARCHAR(150), COUNT DOUBLE); +CREATE TABLE ANALYTICS_EVENT_STORE.SCALING_DETAILS(Time VARCHAR(50), ScalingDecisionId VARCHAR(150), ClusterId VARCHAR(150), MinInstanceCount INT, MaxInstanceCount INT, RIFPredicted INT, RIFThreshold INT ,RIFRequiredInstances INT, MCPredicted INT, MCThreshold INT, MCRequiredInstances INT ,LAPredicted INT, LAThreshold INT,LARequiredInstances INT,RequiredInstanceCount INT ,ActiveInstanceCount INT, AdditionalInstanceCount INT, ScalingReason VARCHAR(150)); http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/wso2cep-300/eventformatters/AverageInFlightRequestsDASEventFormatter.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/wso2cep-300/eventformatters/AverageInFlightRequestsDASEventFormatter.xml b/extensions/das/modules/artifacts/wso2cep-300/eventformatters/AverageInFlightRequestsDASEventFormatter.xml new file mode 100644 index 0000000..498d200 --- /dev/null +++ b/extensions/das/modules/artifacts/wso2cep-300/eventformatters/AverageInFlightRequestsDASEventFormatter.xml @@ -0,0 +1,30 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + + 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. + +--> +<eventFormatter name="AverageRequestsInflightDASEventFormatter" statistics="disable" + trace="enable" xmlns="http://wso2.org/carbon/eventformatter";> + <from streamName="average_in_flight_requests" version="1.0.0"/> + <mapping customMapping="disable" type="wso2event"/> + <to eventAdaptorName="DefaultWSO2EventOutputAdaptor" eventAdaptorType="wso2event"> + <property name="stream">average_in_flight_requests</property> + <property name="version">1.0.0</property> + </to> +</eventFormatter> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/wso2cep-300/eventformatters/AverageLoadAverageDASEventFormatter.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/wso2cep-300/eventformatters/AverageLoadAverageDASEventFormatter.xml b/extensions/das/modules/artifacts/wso2cep-300/eventformatters/AverageLoadAverageDASEventFormatter.xml new file mode 100644 index 0000000..30461c0 --- /dev/null +++ b/extensions/das/modules/artifacts/wso2cep-300/eventformatters/AverageLoadAverageDASEventFormatter.xml @@ -0,0 +1,30 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + + 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. + +--> +<eventFormatter name="AverageLoadAverageDASEventFormatter" statistics="disable" + trace="enable" xmlns="http://wso2.org/carbon/eventformatter";> + <from streamName="average_load_average_stats" version="1.0.0"/> + <mapping customMapping="disable" type="wso2event"/> + <to eventAdaptorName="DefaultWSO2EventOutputAdaptor" eventAdaptorType="wso2event"> + <property name="stream">average_load_average_stats</property> + <property name="version">1.0.0</property> + </to> +</eventFormatter> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/wso2cep-300/eventformatters/AverageMemoryConsumptionDASEventFormatter.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/wso2cep-300/eventformatters/AverageMemoryConsumptionDASEventFormatter.xml b/extensions/das/modules/artifacts/wso2cep-300/eventformatters/AverageMemoryConsumptionDASEventFormatter.xml new file mode 100644 index 0000000..8a3bfaa --- /dev/null +++ b/extensions/das/modules/artifacts/wso2cep-300/eventformatters/AverageMemoryConsumptionDASEventFormatter.xml @@ -0,0 +1,30 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + + 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. + +--> +<eventFormatter name="AverageMemoryConsumptionDASEventFormatter" statistics="disable" + trace="enable" xmlns="http://wso2.org/carbon/eventformatter";> + <from streamName="average_memory_consumption_stats" version="1.0.0"/> + <mapping customMapping="disable" type="wso2event"/> + <to eventAdaptorName="DefaultWSO2EventOutputAdaptor" eventAdaptorType="wso2event"> + <property name="stream">average_memory_consumption_stats</property> + <property name="version">1.0.0</property> + </to> +</eventFormatter> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/wso2cep-300/eventformatters/MemberAverageLoadAverageDASEventFormatter.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/wso2cep-300/eventformatters/MemberAverageLoadAverageDASEventFormatter.xml b/extensions/das/modules/artifacts/wso2cep-300/eventformatters/MemberAverageLoadAverageDASEventFormatter.xml new file mode 100644 index 0000000..934188c --- /dev/null +++ b/extensions/das/modules/artifacts/wso2cep-300/eventformatters/MemberAverageLoadAverageDASEventFormatter.xml @@ -0,0 +1,30 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + + 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. + +--> +<eventFormatter name="MemberAverageLoadAverageDASEventFormatter" statistics="disable" + trace="enable" xmlns="http://wso2.org/carbon/eventformatter";> +<from streamName="member_average_load_average_stats" version="1.0.0"/> +<mapping customMapping="disable" type="wso2event"/> +<to eventAdaptorName="DefaultWSO2EventOutputAdaptor" eventAdaptorType="wso2event"> + <property name="stream">member_average_load_average_stats</property> + <property name="version">1.0.0</property> +</to> +</eventFormatter> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/wso2cep-300/eventformatters/MemberAverageMemoryConsumptionDASEventFormatter.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/wso2cep-300/eventformatters/MemberAverageMemoryConsumptionDASEventFormatter.xml b/extensions/das/modules/artifacts/wso2cep-300/eventformatters/MemberAverageMemoryConsumptionDASEventFormatter.xml new file mode 100644 index 0000000..0ee973c --- /dev/null +++ b/extensions/das/modules/artifacts/wso2cep-300/eventformatters/MemberAverageMemoryConsumptionDASEventFormatter.xml @@ -0,0 +1,30 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + + 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. + +--> +<eventFormatter name="MemberAverageMemoryConsumptionDASEventFormatter" statistics="disable" + trace="enable" xmlns="http://wso2.org/carbon/eventformatter";> + <from streamName="member_average_memory_consumption_stats" version="1.0.0"/> + <mapping customMapping="disable" type="wso2event"/> + <to eventAdaptorName="DefaultWSO2EventOutputAdaptor" eventAdaptorType="wso2event"> + <property name="stream">member_average_memory_consumption_stats</property> + <property name="version">1.0.0</property> + </to> +</eventFormatter> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/wso2cep-300/outputeventadaptors/DefaultWSO2EventOutputAdaptor.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/wso2cep-300/outputeventadaptors/DefaultWSO2EventOutputAdaptor.xml b/extensions/das/modules/artifacts/wso2cep-300/outputeventadaptors/DefaultWSO2EventOutputAdaptor.xml new file mode 100644 index 0000000..97a5780 --- /dev/null +++ b/extensions/das/modules/artifacts/wso2cep-300/outputeventadaptors/DefaultWSO2EventOutputAdaptor.xml @@ -0,0 +1,28 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + + 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. + +--> +<outputEventAdaptor name="DefaultWSO2EventOutputAdaptor" + statistics="disable" trace="disable" type="wso2event" xmlns="http://wso2.org/carbon/eventadaptormanager";> + <property name="username">admin</property> + <property name="receiverURL">tcp://localhost:7612</property> + <property name="password">admin</property> + <property name="authenticatorURL">ssl://localhost:7712</property> +</outputEventAdaptor> http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/wso2cep-310/eventformatters/AverageInFlightRequestsDASEventFormatter.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/wso2cep-310/eventformatters/AverageInFlightRequestsDASEventFormatter.xml b/extensions/das/modules/artifacts/wso2cep-310/eventformatters/AverageInFlightRequestsDASEventFormatter.xml new file mode 100644 index 0000000..498d200 --- /dev/null +++ b/extensions/das/modules/artifacts/wso2cep-310/eventformatters/AverageInFlightRequestsDASEventFormatter.xml @@ -0,0 +1,30 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + + 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. + +--> +<eventFormatter name="AverageRequestsInflightDASEventFormatter" statistics="disable" + trace="enable" xmlns="http://wso2.org/carbon/eventformatter";> + <from streamName="average_in_flight_requests" version="1.0.0"/> + <mapping customMapping="disable" type="wso2event"/> + <to eventAdaptorName="DefaultWSO2EventOutputAdaptor" eventAdaptorType="wso2event"> + <property name="stream">average_in_flight_requests</property> + <property name="version">1.0.0</property> + </to> +</eventFormatter> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/wso2cep-310/eventformatters/AverageLoadAverageDASEventFormatter.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/wso2cep-310/eventformatters/AverageLoadAverageDASEventFormatter.xml b/extensions/das/modules/artifacts/wso2cep-310/eventformatters/AverageLoadAverageDASEventFormatter.xml new file mode 100644 index 0000000..30461c0 --- /dev/null +++ b/extensions/das/modules/artifacts/wso2cep-310/eventformatters/AverageLoadAverageDASEventFormatter.xml @@ -0,0 +1,30 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + + 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. + +--> +<eventFormatter name="AverageLoadAverageDASEventFormatter" statistics="disable" + trace="enable" xmlns="http://wso2.org/carbon/eventformatter";> + <from streamName="average_load_average_stats" version="1.0.0"/> + <mapping customMapping="disable" type="wso2event"/> + <to eventAdaptorName="DefaultWSO2EventOutputAdaptor" eventAdaptorType="wso2event"> + <property name="stream">average_load_average_stats</property> + <property name="version">1.0.0</property> + </to> +</eventFormatter> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/wso2cep-310/eventformatters/AverageMemoryConsumptionDASEventFormatter.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/wso2cep-310/eventformatters/AverageMemoryConsumptionDASEventFormatter.xml b/extensions/das/modules/artifacts/wso2cep-310/eventformatters/AverageMemoryConsumptionDASEventFormatter.xml new file mode 100644 index 0000000..8a3bfaa --- /dev/null +++ b/extensions/das/modules/artifacts/wso2cep-310/eventformatters/AverageMemoryConsumptionDASEventFormatter.xml @@ -0,0 +1,30 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + + 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. + +--> +<eventFormatter name="AverageMemoryConsumptionDASEventFormatter" statistics="disable" + trace="enable" xmlns="http://wso2.org/carbon/eventformatter";> + <from streamName="average_memory_consumption_stats" version="1.0.0"/> + <mapping customMapping="disable" type="wso2event"/> + <to eventAdaptorName="DefaultWSO2EventOutputAdaptor" eventAdaptorType="wso2event"> + <property name="stream">average_memory_consumption_stats</property> + <property name="version">1.0.0</property> + </to> +</eventFormatter> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/wso2cep-310/eventformatters/MemberAverageLoadAverageDASEventFormatter.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/wso2cep-310/eventformatters/MemberAverageLoadAverageDASEventFormatter.xml b/extensions/das/modules/artifacts/wso2cep-310/eventformatters/MemberAverageLoadAverageDASEventFormatter.xml new file mode 100644 index 0000000..934188c --- /dev/null +++ b/extensions/das/modules/artifacts/wso2cep-310/eventformatters/MemberAverageLoadAverageDASEventFormatter.xml @@ -0,0 +1,30 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + + 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. + +--> +<eventFormatter name="MemberAverageLoadAverageDASEventFormatter" statistics="disable" + trace="enable" xmlns="http://wso2.org/carbon/eventformatter";> +<from streamName="member_average_load_average_stats" version="1.0.0"/> +<mapping customMapping="disable" type="wso2event"/> +<to eventAdaptorName="DefaultWSO2EventOutputAdaptor" eventAdaptorType="wso2event"> + <property name="stream">member_average_load_average_stats</property> + <property name="version">1.0.0</property> +</to> +</eventFormatter> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/wso2cep-310/eventformatters/MemberAverageMemoryConsumptionDASEventFormatter.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/wso2cep-310/eventformatters/MemberAverageMemoryConsumptionDASEventFormatter.xml b/extensions/das/modules/artifacts/wso2cep-310/eventformatters/MemberAverageMemoryConsumptionDASEventFormatter.xml new file mode 100644 index 0000000..0ee973c --- /dev/null +++ b/extensions/das/modules/artifacts/wso2cep-310/eventformatters/MemberAverageMemoryConsumptionDASEventFormatter.xml @@ -0,0 +1,30 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + + 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. + +--> +<eventFormatter name="MemberAverageMemoryConsumptionDASEventFormatter" statistics="disable" + trace="enable" xmlns="http://wso2.org/carbon/eventformatter";> + <from streamName="member_average_memory_consumption_stats" version="1.0.0"/> + <mapping customMapping="disable" type="wso2event"/> + <to eventAdaptorName="DefaultWSO2EventOutputAdaptor" eventAdaptorType="wso2event"> + <property name="stream">member_average_memory_consumption_stats</property> + <property name="version">1.0.0</property> + </to> +</eventFormatter> \ No newline at end of file http://git-wip-us.apache.org/repos/asf/stratos/blob/19a021ae/extensions/das/modules/artifacts/wso2cep-310/outputeventadaptors/DefaultWSO2EventOutputAdaptor.xml ---------------------------------------------------------------------- diff --git a/extensions/das/modules/artifacts/wso2cep-310/outputeventadaptors/DefaultWSO2EventOutputAdaptor.xml b/extensions/das/modules/artifacts/wso2cep-310/outputeventadaptors/DefaultWSO2EventOutputAdaptor.xml new file mode 100644 index 0000000..97a5780 --- /dev/null +++ b/extensions/das/modules/artifacts/wso2cep-310/outputeventadaptors/DefaultWSO2EventOutputAdaptor.xml @@ -0,0 +1,28 @@ +<?xml version="1.0" encoding="UTF-8"?> +<!-- + + 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. + +--> +<outputEventAdaptor name="DefaultWSO2EventOutputAdaptor" + statistics="disable" trace="disable" type="wso2event" xmlns="http://wso2.org/carbon/eventadaptormanager";> + <property name="username">admin</property> + <property name="receiverURL">tcp://localhost:7612</property> + <property name="password">admin</property> + <property name="authenticatorURL">ssl://localhost:7712</property> +</outputEventAdaptor>
