Adding workload modules

Adding the ablity to define workloads in modules which can be
referenced from the API.  Breaking out the test execution into
its own class so it will be easier to support ReST or other
interfaces.

Added flake8 and code coverage reports where possible to
merge and verify jobs

Change-Id: Ieb51e4e7e1e989288a6f81f4757709669914a196
JIRA: STORPERF-21
Signed-off-by: mbeierl <mark.beierl@emc.com>

1 files changed, 11 insertions, 3 deletions

diff --git a/storperf/carbon/emitter.py b/storperf/carbon/emitter.py
index 526a96f..e949238 100644
--- a/storperf/carbon/emitter.py
+++ b/storperf/carbon/emitter.py
@@ -8,7 +8,10 @@
 ##############################################################################
 import logging
 
+import calendar
 import socket
+import time
+
 
 class CarbonMetricTransmitter():
 
@@ -19,12 +22,17 @@ class CarbonMetricTransmitter():
         self.logger = logging.getLogger(__name__)
 
     def transmit_metrics(self, metrics):
+        if 'timestamp' in metrics:
+            timestamp = metrics.pop('timestamp')
+        else:
+            timestamp = str(calendar.timegm(time.gmtime()))
+
         self.carbon_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
         self.carbon_socket.connect((self.carbon_host, self.carbon_port))
 
         for key, metric in metrics.items():
-            message = key + " " + metric + "\n"
-            print message
-            self.carbon_socket.send(message)
+            message = key + " " + metric + " " + timestamp
+            self.logger.debug("Metric: " + message)
+            self.carbon_socket.send(message + '\n')
 
         self.carbon_socket.close()