diff options
author | Kerim Gokarslan <kgokarsl@cisco.com> | 2017-09-13 20:26:01 -0700 |
---|---|---|
committer | ahothan <ahothan@cisco.com> | 2017-10-20 00:37:13 -0700 |
commit | f6a699e63dae2bb5779bd757dc62217193139ad9 (patch) | |
tree | 3073883ca7a8a771daeebbfef7f89dcc9f6f2753 /nfvbench/fluentd.py | |
parent | d6d77669fcb13c779d869929a95ec9e9474b3fcf (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.py | 4 |
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 = { |