Ashwin Agate 94510afed9 Check periodically if host is leader ... Check periodically if host continues to be a leader once elected. Failure to check might lead to a situation where the host has lost leadership but is not aware of the situation. If the host is no longer the leader then stand down as a leader, stop any spark-submit processes running on the node and reset state in the transform thread. Removed --supervise option when invoking spark-submit to turn off built in driver management. Added some hardening to better catch exceptions in main transform service thread and also periodic leader check function so that the threads don't die when they encounter an unhandled exception. Change-Id: If2e13e3ed6cb30b3d7fa5f1b440c4c39b87692be		2017-07-05 23:13:29 -07:00
..
component	Started adding kubernetes metrics aggregation	2017-03-02 15:38:25 +00:00
config	Hourly aggregation account for early arrving metrics	2017-04-17 15:29:34 -07:00
data_driven_specs	Started adding kubernetes metrics aggregation	2017-03-02 15:38:25 +00:00
db	Reintroduced some aggregations which were apparently lost when	2016-08-04 15:13:43 +00:00
driver	Merge "Started adding kubernetes metrics aggregation"	2017-03-03 19:18:47 +00:00
messaging	Use to kafka_lib library in monasca common	2017-03-15 16:22:50 -07:00
processor	Hourly aggregation account for early arrving metrics	2017-04-17 15:29:34 -07:00
service	Check periodically if host is leader	2017-07-05 23:13:29 -07:00
transform	Fix development environment and functional tests	2017-04-11 12:13:25 -07:00
__init__.py	monasca-transform initial commit	2016-05-26 00:10:37 +00:00
log_utils.py	Validate metrics before publishing to kafka	2016-09-30 19:07:02 +00:00
mysql_offset_specs.py	Hourly aggregation account for early arrving metrics	2017-04-17 15:29:34 -07:00
offset_specs.py	Started adding kubernetes metrics aggregation	2017-03-02 15:38:25 +00:00