Merge remote-tracking branch 'upstream/main', where "upstream" is yoltq.

1 files changed, 45 insertions, 0 deletions

diff --git a/test/com/github/ivarref/yoltq/http_hang_demo.clj b/test/com/github/ivarref/yoltq/http_hang_demo.clj
new file mode 100644
index 0000000..06d877b
--- /dev/null
+++ b/test/com/github/ivarref/yoltq/http_hang_demo.clj
@@ -0,0 +1,45 @@
+(ns com.github.ivarref.yoltq.http-hang-demo
+  (:require [datomic.api :as d]
+            [com.github.ivarref.yoltq :as yq]
+            [com.github.ivarref.yoltq.log-init])
+  (:import (java.net.http HttpClient HttpRequest HttpResponse$BodyHandlers)))
+
+(comment
+  (do
+    (com.github.ivarref.yoltq.log-init/init-logging!
+      [[#{"datomic.*" "com.datomic.*" "org.apache.*"} :warn]
+       [#{"com.github.ivarref.yoltq.report-queue"} :debug]
+       [#{"com.github.ivarref.yoltq.poller"} :info]
+       [#{"com.github.ivarref.yoltq*"} :debug]
+       [#{"*"} :info]])
+    (yq/stop!)
+    (let [received (atom [])
+          uri (str "datomic:mem://hello-world-" (java.util.UUID/randomUUID))]
+      (d/delete-database uri)
+      (d/create-database uri)
+      (let [conn (d/connect uri)]
+        (init! {:conn                          conn
+                :error-backoff-time            (Duration/ofSeconds 5)
+                :poll-delay                    5
+                :system-error-poll-interval    [1 TimeUnit/MINUTES]
+                :system-error-callback-backoff (Duration/ofHours 1)
+                :max-execute-time              (Duration/ofSeconds 3)
+                :on-system-error               (fn [] (log/error "system in error state"))
+                :on-system-recovery            (fn [] (log/info "system recovered"))})
+        (yq/add-consumer! :slow (fn [_payload]
+                                  (log/info "start slow handler...")
+                                  ; sudo tc qdisc del dev wlp3s0 root netem
+                                  ; sudo tc qdisc add dev wlp3s0 root netem delay 10000ms
+                                  ; https://jvns.ca/blog/2017/04/01/slow-down-your-internet-with-tc/
+                                  (let [request (-> (HttpRequest/newBuilder)
+                                                    (.uri (java.net.URI. "https://postman-echo.com/get"))
+                                                    (.timeout (Duration/ofSeconds 10))
+                                                    (.GET)
+                                                    (.build))]
+                                    (log/info "body is:" (-> (.send (HttpClient/newHttpClient) request (HttpResponse$BodyHandlers/ofString))
+                                                             (.body))))
+                                  (log/info "slow handler is done!")))
+        (yq/start!)
+        @(d/transact conn [(put :slow {:work 123})])
+        #_(dotimes [x 1] @(d/transact conn [(put :q {:work x})]))
+        nil))))
\ No newline at end of file