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 <[email protected]> Authored: Wed Sep 2 20:13:16 2015 +0530 Committer: gayangunarathne <[email protected]> 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)
