You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@stratos.apache.org by ga...@apache.org on 2015/09/04 12:31:55 UTC
stratos git commit: Adding timestamp for cartridge_agent_helath_stats
stream
Repository: stratos
Updated Branches:
refs/heads/master aa50100f4 -> 75cbbbcdd
Adding timestamp for cartridge_agent_helath_stats stream
Project: http://git-wip-us.apache.org/repos/asf/stratos/repo
Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/75cbbbcd
Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/75cbbbcd
Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/75cbbbcd
Branch: refs/heads/master
Commit: 75cbbbcdd33238acdd92fa1d826ead8734d7db5a
Parents: aa50100
Author: Thanuja <th...@wso2.com>
Authored: Wed Sep 2 20:13:16 2015 +0530
Committer: gayangunarathne <ga...@wso2.com>
Committed: Fri Sep 4 14:33:42 2015 +0530
----------------------------------------------------------------------
.../main/python/cartridge.agent/cartridge.agent/healthstats.py | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/stratos/blob/75cbbbcd/components/org.apache.stratos.python.cartridge.agent/src/main/python/cartridge.agent/cartridge.agent/healthstats.py
----------------------------------------------------------------------
diff --git a/components/org.apache.stratos.python.cartridge.agent/src/main/python/cartridge.agent/cartridge.agent/healthstats.py b/components/org.apache.stratos.python.cartridge.agent/src/main/python/cartridge.agent/cartridge.agent/healthstats.py
index f661294..b96ac23 100644
--- a/components/org.apache.stratos.python.cartridge.agent/src/main/python/cartridge.agent/cartridge.agent/healthstats.py
+++ b/components/org.apache.stratos.python.cartridge.agent/src/main/python/cartridge.agent/cartridge.agent/healthstats.py
@@ -19,6 +19,7 @@ from threading import Thread
import multiprocessing
import psutil
+import time
from modules.databridge.agent import *
from config import Config
@@ -139,6 +140,7 @@ class HealthStatisticsPublisher:
stream_def.description = HealthStatisticsPublisherManager.STREAM_DESCRIPTION
# stream_def.add_payloaddata_attribute()
+ stream_def.add_payloaddata_attribute("timestamp", StreamDefinition.LONG)
stream_def.add_payloaddata_attribute("cluster_id", StreamDefinition.STRING)
stream_def.add_payloaddata_attribute("cluster_instance_id", StreamDefinition.STRING)
stream_def.add_payloaddata_attribute("network_partition_id", StreamDefinition.STRING)
@@ -156,6 +158,7 @@ class HealthStatisticsPublisher:
"""
event = ThriftEvent()
+ event.payloadData.append(int(round(time.time() * 1000)))
event.payloadData.append(Config.cluster_id)
event.payloadData.append(Config.cluster_instance_id)
event.payloadData.append(Config.network_partition_id)
@@ -180,6 +183,7 @@ class HealthStatisticsPublisher:
"""
event = ThriftEvent()
+ event.payloadData.append(int(round(time.time() * 1000)))
event.payloadData.append(Config.cluster_id)
event.payloadData.append(Config.cluster_instance_id)
event.payloadData.append(Config.network_partition_id)