add option for status reporting interval

Author: rerpha

forwarder/parse_commandline_args.py

@@ -183,6 +183,14 @@ def parse_args():
         type=int,
         default=1000,
     )
+    parser.add_argument(
+        "--status-interval",
+        help="Period for status updates (units=milliseconds)",
+        required=False,
+        env_var="STATUS_INTERVAL",
+        type=int,
+        default=4000,
+    )
     log_choice_to_enum = {
         "Trace": logging.DEBUG,
         "Debug": logging.DEBUG,

forwarder/scripts/run.py

@@ -81,6 +81,7 @@ def create_status_reporter(
     service_id,
     version,
     logger,
+    status_interval,
 ):
     (
         broker,
@@ -107,6 +108,7 @@ def create_status_reporter(
         service_id,
         version,
         logger,
+        status_interval,
     )
     return status_reporter
 
@@ -249,6 +251,7 @@ def main():
             args.service_id,
             version,
             get_logger(),
+            args.status_interval,
         )
         exit_stack.callback(status_reporter.stop)
         status_reporter.start()

forwarder/status_reporter.py

@@ -22,7 +22,7 @@ def __init__(
         service_id: str,
         version: str,
         logger: Logger,
-        interval_ms: int = 4000,
+        interval_ms: int,
     ):
         self._repeating_timer = RepeatTimer(
             milliseconds_to_seconds(interval_ms), self.report_status