summaryrefslogtreecommitdiffstats
path: root/nfvbench/fluentd.py
diff options
context:
space:
mode:
authorKerim Gokarslan <kgokarsl@cisco.com>2017-09-13 20:26:01 -0700
committerKerim Gokarslan <kgokarsl@cisco.com>2017-09-19 11:40:38 -0700
commit5bfd65ce5753b27c32afb9f84cf5b268f060cb03 (patch)
treec1d27b1b3f937d7deaf1421c8e60dd05c5ccb907 /nfvbench/fluentd.py
parent4e74e931fb22017abffbe0c4dbed668d5be14e54 (diff)
NFVBENCH-25 Send run results to fluentd
Change-Id: I671a9297b90784bc30eee48ea9244a9c63a24e85 Signed-off-by: Kerim Gokarslan <kgokarsl@cisco.com>
Diffstat (limited to 'nfvbench/fluentd.py')
-rw-r--r--nfvbench/fluentd.py4
1 files changed, 4 insertions, 0 deletions
diff --git a/nfvbench/fluentd.py b/nfvbench/fluentd.py
index 93c90fa..a9bda62 100644
--- a/nfvbench/fluentd.py
+++ b/nfvbench/fluentd.py
@@ -61,6 +61,10 @@ class FluentLogHandler(logging.Handler):
self.__update_stats(record.levelno)
self.sender.emit(None, data)
+ # this function is called by summarizer
+ def record_send(self, record):
+ self.sender.emit(None, record)
+
# send START record for each run
def __send_start_record(self):
data = {