diff options
| author |   Alec Hothan <ahothan@cisco.com> | 2017-09-19 19:10:29 +0000 |
|---|---|---|
| committer |   Gerrit Code Review <gerrit@opnfv.org> | 2017-09-19 19:10:29 +0000 |
| commit | 230d84f20f70ebcbafa1f8f3d32461649c8c49b1 (patch) | |
| tree | 3073883ca7a8a771daeebbfef7f89dcc9f6f2753 /nfvbench/fluentd.py | |
| parent | f0210f984f570ae4734d4d06c62363b820e885d6 (diff) | |
| parent | 5bfd65ce5753b27c32afb9f84cf5b268f060cb03 (diff) | |
Merge "NFVBENCH-25 Send run results to fluentd"
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 = { |