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 <[email protected]> Authored: Mon Nov 25 17:00:14 2013 +0530 Committer: Manula Thantriwatte <[email protected]> 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>
