Merge pull request #265 from phenobarbital/pluggable-logger

adding flush timeout to logstash handler

navconfig/logging/handlers/logstash.py

@@ -14,6 +14,12 @@ class LogstashHandler(AbstractLog):
 
     Send Logs to Logstash using Logstash-async.
     """
+    def __init__(self, config, loglevel, application: str) -> None:
+        super(LogstashHandler, self).__init__(config, loglevel, application)
+        self._flush_timeout = config.getint(
+            'logstash_flush_timeout', section='logging', fallback=20
+        )
+
     def formatter(
             self,
             path: str,
@@ -41,6 +47,7 @@ def handler(self, enable_localdb: bool = False, **kwargs):
             'transport_type': 'tcp',
             'host': self.host,
             'port': int(self.port),
+            'flush_timeout': self._flush_timeout,  # set the flush_timeout
             'level': self.loglevel
         }
         if enable_localdb is True:

navconfig/version.py

@@ -3,7 +3,7 @@
 __title__ = 'navconfig'
 __description__ = ('Configuration tool for all Navigator Services '
                    'Tool for accessing Config info from different sources.')
-__version__ = '1.3.2'
+__version__ = '1.3.4'
 __author__ = 'Jesus Lara'
 __author_email__ = '[email protected]'
 __license__ = 'MIT'