Revert "Adding timestamp for cartridge_agent_helath_stats stream"
This reverts commit 75cbbbcdd33238acdd92fa1d826ead8734d7db5a. Project: http://git-wip-us.apache.org/repos/asf/stratos/repo Commit: http://git-wip-us.apache.org/repos/asf/stratos/commit/68a2aa3c Tree: http://git-wip-us.apache.org/repos/asf/stratos/tree/68a2aa3c Diff: http://git-wip-us.apache.org/repos/asf/stratos/diff/68a2aa3c Branch: refs/heads/master Commit: 68a2aa3c38d83c04c3537c1ffa4217a044da99b3 Parents: 7bca8e2 Author: gayangunarathne <[email protected]> Authored: Mon Nov 2 17:00:05 2015 +0530 Committer: gayangunarathne <[email protected]> Committed: Mon Nov 2 17:00:05 2015 +0530 ---------------------------------------------------------------------- .../main/python/cartridge.agent/cartridge.agent/healthstats.py | 4 ---- 1 file changed, 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/stratos/blob/68a2aa3c/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 b96ac23..f661294 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,7 +19,6 @@ from threading import Thread import multiprocessing import psutil -import time from modules.databridge.agent import * from config import Config @@ -140,7 +139,6 @@ 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) @@ -158,7 +156,6 @@ 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) @@ -183,7 +180,6 @@ 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)
