From d358185a04f3cd8f4f45451963fbaba3a7a227d3 Mon Sep 17 00:00:00 2001 From: Andrey Antukh Date: Thu, 10 Feb 2022 00:02:12 +0100 Subject: [PATCH] :lipstick: Minor cosmetic change on database logger processor --- backend/src/app/loggers/database.clj | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/backend/src/app/loggers/database.clj b/backend/src/app/loggers/database.clj index aea476bbb..ebece9af0 100644 --- a/backend/src/app/loggers/database.clj +++ b/backend/src/app/loggers/database.clj @@ -69,12 +69,15 @@ (defmethod ig/pre-init-spec ::reporter [_] (s/keys :req-un [::wrk/executor ::db/pool ::receiver])) +(defn error-event? + [event] + (= "error" (:logger/level event))) + (defmethod ig/init-key ::reporter [_ {:keys [receiver] :as cfg}] (l/info :msg "initializing database error persistence") - (let [output (a/chan (a/sliding-buffer 128) - (filter (fn [event] - (= (:logger/level event) "error"))))] + (let [output (a/chan (a/sliding-buffer 5) + (filter error-event?))] (receiver :sub output) (a/go-loop [] (let [msg (a/