summaryrefslogtreecommitdiffstats
path: root/glances
diff options
context:
space:
mode:
authornicolargo <nicolashennion@gmail.com>2020-02-27 15:17:24 +0100
committernicolargo <nicolashennion@gmail.com>2020-02-27 15:17:24 +0100
commitf6533272a5a61d13a4041d84c43adeffee926aef (patch)
tree4ac21a9b90046ae9a093a94a869ccce73374b725 /glances
parent1e8bf7bd5fdec1d2b8eb85e57a38096466f1b5d9 (diff)
Feature request: Include hostname in all (e.g. kafka) exports #1594
Diffstat (limited to 'glances')
-rw-r--r--glances/exports/glances_kafka.py9
1 files changed, 7 insertions, 2 deletions
diff --git a/glances/exports/glances_kafka.py b/glances/exports/glances_kafka.py
index c328d7f6..88d13bf0 100644
--- a/glances/exports/glances_kafka.py
+++ b/glances/exports/glances_kafka.py
@@ -42,11 +42,14 @@ class Export(GlancesExport):
# Optionals configuration keys
self.compression = None
+ self.tags = None
# Load the Kafka configuration file section
self.export_enable = self.load_conf('kafka',
- mandatories=['host', 'port', 'topic'],
- options=['compression'])
+ mandatories=['host', 'port',
+ 'topic'],
+ options=['compression',
+ 'tags'])
if not self.export_enable:
sys.exit(2)
@@ -79,6 +82,8 @@ class Export(GlancesExport):
# Create DB input
data = dict(zip(columns, points))
+ if self.tags is not None:
+ data.update(self.parse_tags(self.tags))
# Send stats to the kafka topic
# key=<plugin name>