On Tue, Jul 14, 2015 at 9:44 PM, Reka Thirunavukkarasu <r...@wso2.com>
wrote:
>
>
>> 1.getAverageClusterMemoryByClusterId
>>
>
> /cluster/averageMemory/{Id}/{Interval}}
>
>
>> 2.getAverageClusterLoadByClusterId
>>
>
> /cluster/averageLoad/{Id}/{Interval}}
>
>
>> 3.getAverageMemberMemoryByMemberId
>>
>
> /member/averageMemory/{Id}/{Interval}}
>
> 4.getAverageMemberLoadByMemberId
>>
>
> /member/averageLoad/{Id}/{Interval}}
>
>
>> 5.getAverageClusterFlightRequestCountByClusterId
>>
>
> /cluster/flightRequestCount/{Id}/{Interval}}
>
+1 A great thought! @Ashan: It would be better if you can document the API
methods (may be in a Google doc).
Thanks
On Tue, Jul 14, 2015 at 9:44 PM, Reka Thirunavukkarasu <r...@wso2.com>
wrote:
> Hi Ashan,
>
> Wouldn't it be better to stick with the REST API paths currently used by
> stratos? You can inherit and add more stuffs as you want. Please see below
> for some sample paths:
>
> On Tue, Jul 14, 2015 at 1:55 AM, Ashan Dhananjaya <dhananjay...@gmail.com>
> wrote:
>
>> Hi All,
>>
>> I have implemented the REST api methods for the health statistics UI in
>> the stratos existing REST API.
>>
>> 1.getAverageClusterMemoryByClusterId
>>
>
> /cluster/averageMemory/{Id}/{Interval}}
>
>
>> 2.getAverageClusterLoadByClusterId
>>
>
> /cluster/averageLoad/{Id}/{Interval}}
>
>
>> 3.getAverageMemberMemoryByMemberId
>>
>
> /member/averageMemory/{Id}/{Interval}}
>
> 4.getAverageMemberLoadByMemberId
>>
>
> /member/averageLoad/{Id}/{Interval}}
>
>
>> 5.getAverageClusterFlightRequestCountByClusterId
>>
>
> /cluster/flightRequestCount/{Id}/{Interval}}
>
> Thanks,
> Reka
>
>>
>> Please find the Github commit here[1].
>>
>> [1]=
>> https://github.com/apache/stratos/commit/5ab9159744f136e649174f7293adabe5c77fb4bd
>>
>>
>> Thank You!
>> Best Regards,
>> Ashan
>>
>> On Thu, Jul 9, 2015 at 8:30 PM, Ashan Dhananjaya <dhananjay...@gmail.com>
>> wrote:
>>
>>> Noted Lahiru.
>>>
>>> On Thu, Jul 9, 2015 at 7:48 PM, Lahiru Sandaruwan <lahi...@wso2.com>
>>> wrote:
>>>
>>>> Hi Ashan,
>>>>
>>>> Good stuff. It is fine to set the time stamp from CEP for now. But
>>>> ultimately we need the timestamp to be sent from Python cartridge agent.
>>>> Let's fix that part we proceed.
>>>>
>>>> Thanks.
>>>>
>>>> On Thu, Jul 9, 2015 at 7:38 PM, Ashan Dhananjaya <
>>>> dhananjay...@gmail.com> wrote:
>>>>
>>>>> Hi All,
>>>>>
>>>>> I was able to get the TimeaStamp to the RDBMS without any conflict
>>>>> AFAIK. I am testing the flow more. Please find the commits [1], [2] for
>>>>> the
>>>>> Formatters.
>>>>>
>>>>> [1]=
>>>>> https://github.com/ashandk/stratos/commit/efa25eb255cadbf2843e5f0d0e13b34c09535f91
>>>>> [2]=
>>>>> https://github.com/ashandk/stratos/commit/9c0fce9081c299c34031d602c94ea712602c7a6c
>>>>>
>>>>> Thank You!
>>>>> Best Regards,
>>>>> Ashan
>>>>>
>>>>> On Thu, Jul 9, 2015 at 2:41 PM, Lahiru Sandaruwan <lahi...@wso2.com>
>>>>> wrote:
>>>>>
>>>>>> Great work Ashan.
>>>>>>
>>>>>> On Thu, Jul 9, 2015 at 2:39 PM, Ashan Dhananjaya <
>>>>>> dhananjay...@gmail.com> wrote:
>>>>>>
>>>>>>> Hi All,
>>>>>>>
>>>>>>> I was able to take the timestamp from the cartridge agent
>>>>>>> (WSO2CEPHealthStatisticsPublisher and WSO2CEPInFlightRequestPublisher)
>>>>>>> to
>>>>>>> CEP PayLoad definition.Git Hub commits can be found here[1], [2].
>>>>>>> Currently
>>>>>>> working on sending the timestamp to the RDBMS without conflicting
>>>>>>> execution
>>>>>>> plans.
>>>>>>>
>>>>>>> I have included the read-me [2] file to the cep extensions how to
>>>>>>> configure should happen for the Health Stat publishing to the RDBMS.
>>>>>>>
>>>>>>> [1]=
>>>>>>> https://github.com/apache/stratos/commit/4c65e705be822fd420b4e48ebafef789c8686b76
>>>>>>> [2]=
>>>>>>> https://github.com/apache/stratos/commit/e09334cd98f245a4633c992f02db2878ac24d3d0
>>>>>>> [3]=
>>>>>>> https://github.com/apache/stratos/commit/5ca895ef030f6aaeba56183d982aa5ae95db9337
>>>>>>>
>>>>>>> Thank You!
>>>>>>> Best Regards,
>>>>>>> Ashan
>>>>>>>
>>>>>>> On Tue, Jul 7, 2015 at 1:13 PM, Lasantha Fernando <
>>>>>>> lasantha....@gmail.com> wrote:
>>>>>>>
>>>>>>>> Hi Ashan,
>>>>>>>>
>>>>>>>> Currently, you would not be able to get the timestamp out of the
>>>>>>>> event
>>>>>>>> unless you use a databridge agent callback. In that case, you can
>>>>>>>> use
>>>>>>>> Java code to simply get by calling event.getTimestamp().
>>>>>>>>
>>>>>>>> However, if you want to use the timestamp as an attribute while
>>>>>>>> doing
>>>>>>>> processing within CEP, you would have to pass the timestamp as an
>>>>>>>> attribute of the stream. i.e. add it as an attribute of either meta,
>>>>>>>> correlation or payload data. Then you can use that timestamp and
>>>>>>>> format the output event as necessary.
>>>>>>>>
>>>>>>>> Thanks,
>>>>>>>> Lasantha
>>>>>>>>
>>>>>>>> On Tue, Jul 7, 2015 at 1:04 PM, Ashan Dhananjaya <
>>>>>>>> dhananjay...@gmail.com> wrote:
>>>>>>>> > Hi All,
>>>>>>>> >
>>>>>>>> > I applied the above patch and get the timestamp in the Input
>>>>>>>> Adapter. The
>>>>>>>> > formatter i used was
>>>>>>>> "member_average_memory_consumption_stats:1.0.0". I
>>>>>>>> > tried several time to get the timeStamp attribute but failed. Is
>>>>>>>> there any
>>>>>>>> > way to get a data which is outside in the payload? The Input
>>>>>>>> stream is as
>>>>>>>> > below,
>>>>>>>> >
>>>>>>>> > 10:40:27,757 [-] [DataBridge-Core-pool-2-thread-1] INFO
>>>>>>>> TenantId=-1234 :
>>>>>>>> > Input Event Adaptor : DefaultWSO2EventInputAdaptor, received
>>>>>>>> >
>>>>>>>> > Event{
>>>>>>>> > streamId='cartridge_agent_health_stats:1.0.0',
>>>>>>>> > timeStamp=1436245827731,
>>>>>>>> > metaData=null,
>>>>>>>> > correlationData=null,
>>>>>>>> > payloadData=[single-cartridge-app.my-php.php.domain,
>>>>>>>> > single-cartridge-app-1, network-partition-1,
>>>>>>>> >
>>>>>>>> single-cartridge-app.my-php.php.domaina5598e2b-995f-4620-b652-e66341e24c99,
>>>>>>>> > partition-1, memory_consumption, 20.0],
>>>>>>>> > arbitraryDataMap={},
>>>>>>>> > }
>>>>>>>> >
>>>>>>>> > Any help will be really appreciated.
>>>>>>>> >
>>>>>>>> > Thank You!
>>>>>>>> > Best Regards,
>>>>>>>> > Ashan
>>>>>>>> >
>>>>>>>> > On Tue, Jul 7, 2015 at 9:32 AM, Chamila De Alwis <
>>>>>>>> chami...@wso2.com> wrote:
>>>>>>>> >>
>>>>>>>> >> Hi Ashan,
>>>>>>>> >>
>>>>>>>> >> As I've seen from the PCA testing recently, the timestamp is
>>>>>>>> added to
>>>>>>>> >> every ThriftEvent before publishing. Are you working on PCA or
>>>>>>>> the Mock
>>>>>>>> >> IaaS? I took a look at the Mock IaaS and the
>>>>>>>> WSO2CEPStatisticsPublisher as
>>>>>>>> >> well, and found out that the latter indeed doesn't add the
>>>>>>>> timestamp to the
>>>>>>>> >> ThriftEvents. This means that the JCA also publishes Thrift
>>>>>>>> Events with
>>>>>>>> >> empty timestamp fields.
>>>>>>>> >>
>>>>>>>> >> Following is the simple fix for that. I've attached the patch
>>>>>>>> herewith.
>>>>>>>> >> Could you quickly verify with the patch applied build also?
>>>>>>>> >>
>>>>>>>> >> chamilad@chamilad-ThinkPad-T530:~/dev/stratos[master *]$ git
>>>>>>>> diff
>>>>>>>> >> diff --git
>>>>>>>> >>
>>>>>>>> a/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/wso2/cep/WSO2CEPStatisticsPublisher.java
>>>>>>>> >> b/c
>>>>>>>> >> index 653288d..f1fe426 100644
>>>>>>>> >> ---
>>>>>>>> >>
>>>>>>>> a/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/wso2/cep/WSO2CEPStatisticsPublisher.java
>>>>>>>> >> +++
>>>>>>>> >>
>>>>>>>> b/components/org.apache.stratos.common/src/main/java/org/apache/stratos/common/statistics/publisher/wso2/cep/WSO2CEPStatisticsPublisher.java
>>>>>>>> >> @@ -29,6 +29,7 @@ import
>>>>>>>> >> org.wso2.carbon.databridge.agent.thrift.exception.AgentException;
>>>>>>>> >> import org.wso2.carbon.databridge.commons.Event;
>>>>>>>> >> import org.wso2.carbon.databridge.commons.StreamDefinition;
>>>>>>>> >>
>>>>>>>> >> +import java.util.Date;
>>>>>>>> >> import java.util.HashMap;
>>>>>>>> >>
>>>>>>>> >> /**
>>>>>>>> >> @@ -98,6 +99,7 @@ public class WSO2CEPStatisticsPublisher
>>>>>>>> implements
>>>>>>>> >> StatisticsPublisher {
>>>>>>>> >>
>>>>>>>> >> Event event = new Event();
>>>>>>>> >> event.setPayloadData(payload);
>>>>>>>> >> + event.setTimeStamp(new Date().getTime());
>>>>>>>> >> event.setArbitraryDataMap(new HashMap<String,
>>>>>>>> String>());
>>>>>>>> >>
>>>>>>>> >> try {
>>>>>>>> >>
>>>>>>>> >>
>>>>>>>> >>
>>>>>>>> >>
>>>>>>>> >>
>>>>>>>> >> Regards,
>>>>>>>> >> Chamila de Alwis
>>>>>>>> >> Committer and PMC Member - Apache Stratos
>>>>>>>> >> Software Engineer | WSO2 | +94772207163
>>>>>>>> >> Blog: code.chamiladealwis.com
>>>>>>>> >>
>>>>>>>> >>
>>>>>>>> >
>>>>>>>>
>>>>>>>
>>>>>>>
>>>>>>
>>>>>>
>>>>>> --
>>>>>> --
>>>>>> Lahiru Sandaruwan
>>>>>> Committer and PMC member, Apache Stratos,
>>>>>> Senior Software Engineer,
>>>>>> WSO2 Inc., http://wso2.com
>>>>>> lean.enterprise.middleware
>>>>>>
>>>>>> phone: +94773325954
>>>>>> email: lahi...@wso2.com blog: http://lahiruwrites.blogspot.com/
>>>>>> linked-in: http://lk.linkedin.com/pub/lahiru-sandaruwan/16/153/146
>>>>>>
>>>>>>
>>>>>> _______________________________________________
>>>>>> Dev mailing list
>>>>>> d...@wso2.org
>>>>>> http://wso2.org/cgi-bin/mailman/listinfo/dev
>>>>>>
>>>>>>
>>>>>
>>>>
>>>>
>>>> --
>>>> --
>>>> Lahiru Sandaruwan
>>>> Committer and PMC member, Apache Stratos,
>>>> Senior Software Engineer,
>>>> WSO2 Inc., http://wso2.com
>>>> lean.enterprise.middleware
>>>>
>>>> phone: +94773325954
>>>> email: lahi...@wso2.com blog: http://lahiruwrites.blogspot.com/
>>>> linked-in: http://lk.linkedin.com/pub/lahiru-sandaruwan/16/153/146
>>>>
>>>>
>>>
>>
>
>
> --
> Reka Thirunavukkarasu
> Senior Software Engineer,
> WSO2, Inc.:http://wso2.com,
> Mobile: +94776442007
>
>
>
--
Imesh Gunaratne
Senior Technical Lead, WSO2
Committer & PMC Member, Apache Stratos
