[mq] [new] Undocumented worker option to support persistent summary s…

…tats
taoensso · Dec 23, 2022 · 641d127 · 641d127
1 parent 603a02e
commit 641d127
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/src/taoensso/carmine/message_queue.clj b/src/taoensso/carmine/message_queue.clj
@@ -853,9 +853,11 @@
            (enc/future-pool nthreads-handler)
            (atom [])
            (atom {})
-           (tukey/summary-stats-buffered {:buffer-size 10000})
-           (tukey/summary-stats-buffered {:buffer-size 10000})
-           (tukey/summary-stats-buffered {:buffer-size 10000}))
+
+           ;; :sstats-init opts below allow for manual persistent sstats, currently undocumented
+           (tukey/summary-stats-buffered {:buffer-size 10000 :sstats-init (get worker-opts :sstats-init/queue-size)})
+           (tukey/summary-stats-buffered {:buffer-size 10000 :sstats-init (get worker-opts :sstats-init/queueing-time-ms)})
+           (tukey/summary-stats-buffered {:buffer-size 10000 :sstats-init (get worker-opts :sstats-init/handling-time-ns)}))
 
          ;; Back compatibility
          auto-start (get worker-opts :auto-start? auto-start)]