monitor the connector flush config

to make it easier to track the effects of changing these values

src/main/scala/Monitor.scala

@@ -181,3 +181,10 @@ object Monitor:
         val expirable = Kamon.gauge("evalCache.upgrade.expirable").withTag("style", key)
     val single = Style("single")
     val multi  = Style("multi")
+
+  object connector:
+    object flush:
+      object config:
+        val step     = Kamon.gauge("connector.flush.config.step").withoutTags()
+        val interval = Kamon.gauge("connector.flush.config.interval").withoutTags()
+        val maxDelay = Kamon.gauge("connector.flush.config.maxDelay").withoutTags()

src/main/scala/netty/ActorChannelConnector.scala

@@ -22,9 +22,15 @@ final private class ActorChannelConnector(
   private val interval = intSetting("netty.flush.interval-millis")
   private val maxDelay = intSetting("netty.flush.max-delay-millis")
   private val flushQ   = new java.util.concurrent.ConcurrentLinkedQueue[Channel]()
+  private val monitor  = Monitor.connector.flush
 
   scheduler.scheduleOnce(1 second, () => flush())
 
+  scheduler.scheduleWithFixedDelay(1 minute, 1 minute): () =>
+    monitor.config.step.update(step.get)
+    monitor.config.interval.update(interval.get)
+    monitor.config.maxDelay.update(maxDelay.get)
+
   def apply(endpoint: Endpoint, channel: Channel): Unit =
     val clientPromise = Promise[Client]()
     channel.attr(key.client).set(clientPromise.future)