chore: raise_e optional support in LogstashHandler

CHANGELOG.md

@@ -13,7 +13,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 
 ### Changed
 
-*
+* Optional `raise_e` support in `LogstashHandler`
 
 ### Fixed
 

src/netius/base/log.py

@@ -92,7 +92,7 @@ def is_ready(cls):
             return False
         return True
 
-    def emit(self, record):
+    def emit(self, record, raise_e=False):
         from . import common
 
         # verifies if the API structure is defined and set and if
@@ -145,9 +145,12 @@ def emit(self, record):
         should_flush = len(self.messages) >= self.max_length
         should_flush = should_flush or time.time() - self._last_flush > self.timeout
         if should_flush:
-            self.flush()
+            try:
+                self.flush(raise_e=raise_e)
+            except Exception:
+                if raise_e: raise
 
-    def flush(self, force=False):
+    def flush(self, force=False, raise_e=False):
         logging.Handler.flush(self)
 
         # verifies if the API structure is defined and set and if
@@ -163,7 +166,7 @@ def flush(self, force=False):
 
         # posts the complete set of messages to logstash and then clears the messages
         # and updates the last flush time
-        self.api.log_bulk(messages, tag="default")
+        self.api.log_bulk(messages, tag="default", raise_e=raise_e)
         self.messages = []
         self.last_flush = time.time()