You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by ma...@apache.org on 2013/11/25 12:31:24 UTC
git commit: Add CEP extensions which are used to summerized health
agent stats
Updated Branches:
refs/heads/master efc45dbbb -> da391046f
Add CEP extensions which are used to summerized health agent stats
Project: http://git-wip-us.apache.org/repos/asf/incubator-stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-stratos/commit/da391046
Tree: http://git-wip-us.apache.org/repos/asf/incubator-stratos/tree/da391046
Diff: http://git-wip-us.apache.org/repos/asf/incubator-stratos/diff/da391046
Branch: refs/heads/master
Commit: da391046fefcb5a296af02dee0c4ae6229045201
Parents: efc45db
Author: Manula Thantriwatte <ma...@apache.org>
Authored: Mon Nov 25 17:00:14 2013 +0530
Committer: Manula Thantriwatte <ma...@apache.org>
Committed: Mon Nov 25 17:00:14 2013 +0530
----------------------------------------------------------------------
.../HealthStatisticsEventBuilder.xml | 10 ++++++++
.../AverageLoadAverageEventFormatter.xml | 11 +++++++++
.../AverageMemoryConsumptionEventFormatter.xml | 11 +++++++++
.../FaultMessageEventFormatter.xml | 11 +++++++++
.../GradientLoadAverageEventFormatter.xml | 11 +++++++++
.../GradientMemoryConsumptionEventFormatter.xml | 11 +++++++++
...econdDerivativeLoadAverageEventFormatter.xml | 11 +++++++++
...erivativeMemoryConsumptionEventFormatter.xml | 11 +++++++++
.../executionplans/AverageHeathRequest.xml | 21 +++++++++++++++++
.../executionplans/GradientOfHealthRequest.xml | 24 ++++++++++++++++++++
.../SecondDerivativeOfHealthRequest.xml | 21 +++++++++++++++++
11 files changed, 153 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/da391046/extensions/cep/artifacts/eventbuilders/HealthStatisticsEventBuilder.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/artifacts/eventbuilders/HealthStatisticsEventBuilder.xml b/extensions/cep/artifacts/eventbuilders/HealthStatisticsEventBuilder.xml
new file mode 100644
index 0000000..cff277f
--- /dev/null
+++ b/extensions/cep/artifacts/eventbuilders/HealthStatisticsEventBuilder.xml
@@ -0,0 +1,10 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<eventBuilder name="HealthStatisticsEventBuilder" statistics="disable"
+ trace="enable" xmlns="http://wso2.org/carbon/eventbuilder">
+ <from eventAdaptorName="DefaultWSO2EventInputAdaptor" eventAdaptorType="wso2event">
+ <property name="stream">stratos.agent.health.stats</property>
+ <property name="version">1.0.0</property>
+ </from>
+ <mapping customMapping="disable" type="wso2event"/>
+ <to streamName="stratos.agent.health.stats" version="1.0.0"/>
+</eventBuilder>
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/da391046/extensions/cep/artifacts/eventformatters/AverageLoadAverageEventFormatter.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/artifacts/eventformatters/AverageLoadAverageEventFormatter.xml b/extensions/cep/artifacts/eventformatters/AverageLoadAverageEventFormatter.xml
new file mode 100644
index 0000000..19593dc
--- /dev/null
+++ b/extensions/cep/artifacts/eventformatters/AverageLoadAverageEventFormatter.xml
@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<eventFormatter name="AverageLoadAverageEventFormatter"
+ statistics="disable" trace="enable" xmlns="http://wso2.org/carbon/eventformatter">
+ <from streamName="average_load_average_stats" version="1.0.0"/>
+ <mapping customMapping="enable" type="json">
+ <inline>{"average_load_average":{"member_id":"{{member_id}}","value":"{{average_load_average}}"}}</inline>
+ </mapping>
+ <to eventAdaptorName="JMSOutputAdaptor" eventAdaptorType="jms">
+ <property name="transport.jms.Destination">summarized-health-stats</property>
+ </to>
+</eventFormatter>
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/da391046/extensions/cep/artifacts/eventformatters/AverageMemoryConsumptionEventFormatter.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/artifacts/eventformatters/AverageMemoryConsumptionEventFormatter.xml b/extensions/cep/artifacts/eventformatters/AverageMemoryConsumptionEventFormatter.xml
new file mode 100644
index 0000000..02776d4
--- /dev/null
+++ b/extensions/cep/artifacts/eventformatters/AverageMemoryConsumptionEventFormatter.xml
@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<eventFormatter name="AverageMemoryConsumptionEventFormatter"
+ statistics="disable" trace="enable" xmlns="http://wso2.org/carbon/eventformatter">
+ <from streamName="average_memory_consumption_stats" version="1.0.0"/>
+ <mapping customMapping="enable" type="json">
+ <inline>{"average_memory_consumption":{"member_id":"{{member_id}}","value":"{{average_memory_consumption}}"}}</inline>
+ </mapping>
+ <to eventAdaptorName="JMSOutputAdaptor" eventAdaptorType="jms">
+ <property name="transport.jms.Destination">summarized-health-stats</property>
+ </to>
+</eventFormatter>
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/da391046/extensions/cep/artifacts/eventformatters/FaultMessageEventFormatter.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/artifacts/eventformatters/FaultMessageEventFormatter.xml b/extensions/cep/artifacts/eventformatters/FaultMessageEventFormatter.xml
new file mode 100644
index 0000000..eae24c9
--- /dev/null
+++ b/extensions/cep/artifacts/eventformatters/FaultMessageEventFormatter.xml
@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<eventFormatter name="FaultMessageEventFormatter"
+ statistics="disable" trace="enable" xmlns="http://wso2.org/carbon/eventformatter">
+ <from streamName="fault_message" version="1.0.0"/>
+ <mapping customMapping="enable" type="json">
+ <inline>{"fault_message":{"member_id":"{{member_id}}"}}</inline>
+ </mapping>
+ <to eventAdaptorName="JMSOutputAdaptor" eventAdaptorType="jms">
+ <property name="transport.jms.Destination">summarized-health-stats</property>
+ </to>
+</eventFormatter>
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/da391046/extensions/cep/artifacts/eventformatters/GradientLoadAverageEventFormatter.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/artifacts/eventformatters/GradientLoadAverageEventFormatter.xml b/extensions/cep/artifacts/eventformatters/GradientLoadAverageEventFormatter.xml
new file mode 100644
index 0000000..9b733f4
--- /dev/null
+++ b/extensions/cep/artifacts/eventformatters/GradientLoadAverageEventFormatter.xml
@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<eventFormatter name="GradientLoadAverageEventFormatter"
+ statistics="disable" trace="enable" xmlns="http://wso2.org/carbon/eventformatter">
+ <from streamName="gradient_load_average_stats" version="1.0.0"/>
+ <mapping customMapping="enable" type="json">
+ <inline>{"gradient_load_average":{"member_id":"{{member_id}}","value":"{{gradient_load_average}}"}}</inline>
+ </mapping>
+ <to eventAdaptorName="JMSOutputAdaptor" eventAdaptorType="jms">
+ <property name="transport.jms.Destination">summarized-health-stats</property>
+ </to>
+</eventFormatter>
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/da391046/extensions/cep/artifacts/eventformatters/GradientMemoryConsumptionEventFormatter.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/artifacts/eventformatters/GradientMemoryConsumptionEventFormatter.xml b/extensions/cep/artifacts/eventformatters/GradientMemoryConsumptionEventFormatter.xml
new file mode 100644
index 0000000..f82112a
--- /dev/null
+++ b/extensions/cep/artifacts/eventformatters/GradientMemoryConsumptionEventFormatter.xml
@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<eventFormatter name="GradientMemoryConsumptionEventFormatter"
+ statistics="disable" trace="enable" xmlns="http://wso2.org/carbon/eventformatter">
+ <from streamName="gradient_memory_consumption_stats" version="1.0.0"/>
+ <mapping customMapping="enable" type="json">
+ <inline>{"gradient_memory_consumption":{"member_id":"{{member_id}}","value":"{{gradient_memory_consumption}}"}}</inline>
+ </mapping>
+ <to eventAdaptorName="JMSOutputAdaptor" eventAdaptorType="jms">
+ <property name="transport.jms.Destination">summarized-health-stats</property>
+ </to>
+</eventFormatter>
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/da391046/extensions/cep/artifacts/eventformatters/SecondDerivativeLoadAverageEventFormatter.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/artifacts/eventformatters/SecondDerivativeLoadAverageEventFormatter.xml b/extensions/cep/artifacts/eventformatters/SecondDerivativeLoadAverageEventFormatter.xml
new file mode 100644
index 0000000..1cd3d85
--- /dev/null
+++ b/extensions/cep/artifacts/eventformatters/SecondDerivativeLoadAverageEventFormatter.xml
@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<eventFormatter name="SecondDerivativeLoadAverageEventFormatter"
+ statistics="disable" trace="disable" xmlns="http://wso2.org/carbon/eventformatter">
+ <from streamName="second_derivative_load_average_stats" version="1.0.0"/>
+ <mapping customMapping="enable" type="json">
+ <inline>{"second_derivative_load_average":{"member_id":"{{member_id}}","value":"{{second_derivative_load_average}}"}}</inline>
+ </mapping>
+ <to eventAdaptorName="JMSOutputAdaptor" eventAdaptorType="jms">
+ <property name="transport.jms.Destination">summarized-health-stats</property>
+ </to>
+</eventFormatter>
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/da391046/extensions/cep/artifacts/eventformatters/SecondDerivativeMemoryConsumptionEventFormatter.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/artifacts/eventformatters/SecondDerivativeMemoryConsumptionEventFormatter.xml b/extensions/cep/artifacts/eventformatters/SecondDerivativeMemoryConsumptionEventFormatter.xml
new file mode 100644
index 0000000..4ae867e
--- /dev/null
+++ b/extensions/cep/artifacts/eventformatters/SecondDerivativeMemoryConsumptionEventFormatter.xml
@@ -0,0 +1,11 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<eventFormatter name="SecondDerivativeMemoryConsumptionEventFormatter"
+ statistics="disable" trace="disable" xmlns="http://wso2.org/carbon/eventformatter">
+ <from streamName="second_derivative_memory_consumption_stats" version="1.0.0"/>
+ <mapping customMapping="enable" type="json">
+ <inline>{"second_derivative_memory_consumption":{"member_id":"{{member_id}}","value":"{{second_derivative_memory_consumption}}"}}</inline>
+ </mapping>
+ <to eventAdaptorName="JMSOutputAdaptor" eventAdaptorType="jms">
+ <property name="transport.jms.Destination">summarized-health-stats</property>
+ </to>
+</eventFormatter>
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/da391046/extensions/cep/artifacts/executionplans/AverageHeathRequest.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/artifacts/executionplans/AverageHeathRequest.xml b/extensions/cep/artifacts/executionplans/AverageHeathRequest.xml
new file mode 100644
index 0000000..cfb9166
--- /dev/null
+++ b/extensions/cep/artifacts/executionplans/AverageHeathRequest.xml
@@ -0,0 +1,21 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<executionPlan name="AverageHeathRequest" statistics="disable"
+ trace="enable" xmlns="http://wso2.org/carbon/eventprocessor">
+ <description>This will average health stats of an instance over a minute.</description>
+ <siddhiConfiguration>
+ <property name="siddhi.enable.distributed.processing">false</property>
+ <property name="siddhi.persistence.snapshot.time.interval.minutes">0</property>
+ </siddhiConfiguration>
+ <importedStreams>
+ <stream as="healthStats1" name="stratos.agent.health.stats" version="1.0.0"/>
+ </importedStreams>
+ <queryExpressions><![CDATA[define partition healthStats1Partition by member_id;
+ from healthStats1 [health_description == 'load_average'] #window.timeBatch(1 min) select member_id, avg(value) as average_load_average insert into average_load_average_stats partition by healthStats1Partition;
+ from healthStats1 [health_description == 'memory_consumption'] #window.timeBatch(1 min) select member_id, avg(value) as average_memory_consumption insert into average_memory_consumption_stats partition by healthStats1Partition;]]></queryExpressions>
+ <exportedStreams>
+ <stream name="average_load_average_stats" passthroughFlow="disable"
+ valueOf="average_load_average_stats" version="1.0.0"/>
+ <stream name="average_memory_consumption_stats" passthroughFlow="disable"
+ valueOf="average_memory_consumption_stats" version="1.0.0"/>
+ </exportedStreams>
+</executionPlan>
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/da391046/extensions/cep/artifacts/executionplans/GradientOfHealthRequest.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/artifacts/executionplans/GradientOfHealthRequest.xml b/extensions/cep/artifacts/executionplans/GradientOfHealthRequest.xml
new file mode 100644
index 0000000..4e27fb7
--- /dev/null
+++ b/extensions/cep/artifacts/executionplans/GradientOfHealthRequest.xml
@@ -0,0 +1,24 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<executionPlan name="GradientOfHealthRequest" statistics="disable"
+ trace="enable" xmlns="http://wso2.org/carbon/eventprocessor">
+ <description>This will find the gradient of the heath request over a minute.</description>
+ <siddhiConfiguration>
+ <property name="siddhi.enable.distributed.processing">false</property>
+ <property name="siddhi.persistence.snapshot.time.interval.minutes">0</property>
+ </siddhiConfiguration>
+ <importedStreams>
+ <stream as="healthStats2" name="stratos.agent.health.stats" version="1.0.0"/>
+ </importedStreams>
+ <queryExpressions><![CDATA[define partition healthStats2Partition by member_id;
+ from healthStats2 #window.stratos:faultHandling(1min, member_id) select member_id insert into fault_message partition by healthStats2Partition;
+ from healthStats2 [health_description == 'load_average'] #window.stratos:gradient(1 min, value) select member_id, value as gradient_load_average insert into gradient_load_average_stats partition by healthStats2Partition;
+ from healthStats2 [health_description == 'memory_consumption'] #window.stratos:gradient(1 min, value) select member_id, value as gradient_memory_consumption insert into gradient_memory_consumption_stats partition by healthStats2Partition;]]></queryExpressions>
+ <exportedStreams>
+ <stream name="gradient_load_average_stats" passthroughFlow="disable"
+ valueOf="gradient_load_average_stats" version="1.0.0"/>
+ <stream name="gradient_memory_consumption_stats" passthroughFlow="disable"
+ valueOf="gradient_memory_consumption_stats" version="1.0.0"/>
+ <stream name="fault_message" passthroughFlow="disable"
+ valueOf="fault_message" version="1.0.0"/>
+ </exportedStreams>
+</executionPlan>
http://git-wip-us.apache.org/repos/asf/incubator-stratos/blob/da391046/extensions/cep/artifacts/executionplans/SecondDerivativeOfHealthRequest.xml
----------------------------------------------------------------------
diff --git a/extensions/cep/artifacts/executionplans/SecondDerivativeOfHealthRequest.xml b/extensions/cep/artifacts/executionplans/SecondDerivativeOfHealthRequest.xml
new file mode 100644
index 0000000..fd7c8d9
--- /dev/null
+++ b/extensions/cep/artifacts/executionplans/SecondDerivativeOfHealthRequest.xml
@@ -0,0 +1,21 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<executionPlan name="SecondDerivativeOfHealthRequest"
+ statistics="disable" trace="enable" xmlns="http://wso2.org/carbon/eventprocessor">
+ <description>This will find the second derivative of health stats over a minute.</description>
+ <siddhiConfiguration>
+ <property name="siddhi.enable.distributed.processing">false</property>
+ <property name="siddhi.persistence.snapshot.time.interval.minutes">0</property>
+ </siddhiConfiguration>
+ <importedStreams>
+ <stream as="healthStats3" name="stratos.agent.health.stats" version="1.0.0"/>
+ </importedStreams>
+ <queryExpressions><![CDATA[define partition healthStats3Partition by member_id;
+ from healthStats3 [health_description == 'memory_consumption'] #window.stratos:secondDerivative(1 min, value) select member_id, value as second_derivative_memory_consumption insert into second_derivative_memory_consumption_stats partition by healthStats3Partition;
+ from healthStats3 [health_description == 'load_average'] #window.stratos:secondDerivative(1 min, value) select member_id, value as second_derivative_load_average insert into second_derivative_load_average_stats partition by healthStats3Partition;]]></queryExpressions>
+ <exportedStreams>
+ <stream name="second_derivative_memory_consumption_stats" passthroughFlow="disable"
+ valueOf="second_derivative_memory_consumption_stats" version="1.0.0"/>
+ <stream name="second_derivative_load_average_stats" passthroughFlow="disable"
+ valueOf="second_derivative_load_average_stats" version="1.0.0"/>
+ </exportedStreams>
+</executionPlan>