luciano/telemere
1
0
Fork 0
mirror of https://github.com/taoensso/telemere.git synced 2025-12-18 02:01:11 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

[mod] Default signal-content-fn: omit redundant parent/root id namespaces

Browse source
This commit is contained in:
Peter Taoussanis 2024-11-12 10:55:05 +01:00
parent b208532788
commit 55323f1f54
1 changed files with 9 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
projects/main/src/taoensso/telemere/utils.cljc
View file

@ -544,6 +544,11 @@
(comment ((signal-preamble-fn) (tel/with-signal (tel/event! ::ev-id)))) (comment ((signal-preamble-fn) (tel/with-signal (tel/event! ::ev-id))))
(defn- format-parent [ns {:keys [id uid]}]
{:id (symbol (sigs/format-id ns id)) :uid uid})
(comment (str (format-parent (str *ns*) {:id ::foo})))
(defn signal-content-fn (defn signal-content-fn
"Experimental, subject to change. "Experimental, subject to change.
Returns a (fn content [signal]) that: Returns a (fn content [signal]) that:
@ -584,15 +589,15 @@
(let [af append-fn (let [af append-fn
vf val-fn] vf val-fn]
(let [{:keys [uid parent root data kvs ctx #?@(:clj [host thread]) sample-rate]} signal] (let [{:keys [ns uid parent root data kvs ctx #?@(:clj [host thread]) sample-rate]} signal]
(when sample-rate (af " sample: " (vf sample-rate))) (when sample-rate (af " sample: " (vf sample-rate)))
(when uid (af " uid: " (vf uid))) (when uid (af " uid: " (vf uid)))
(when parent (when parent
(if (= parent root) (if (= parent root)
(do (af " parent: " (vf (dissoc parent :inst)) " (also root)")) ; {:keys [id uid]} (do (af " parent: " (vf (format-parent ns parent)) " (also root)")) ; {:keys [id uid]}
(do (do
(do (af " parent: " (vf (dissoc parent :inst)))) ; {:keys [id uid]} (do (af " parent: " (vf (format-parent ns parent)))) ; {:keys [id uid]}
(when root (af " root: " (vf (dissoc root :inst))))))) ; {:keys [id uid]} (when root (af " root: " (vf (format-parent ns root))))))) ; {:keys [id uid]}
#?(:clj (when (enc/and* host incl-host?) (af " host: " (vf host)))) ; {:keys [ name ip]} #?(:clj (when (enc/and* host incl-host?) (af " host: " (vf host)))) ; {:keys [ name ip]}
#?(:clj (when (enc/and* thread incl-thread?) (af " thread: " (vf thread)))) ; {:keys [group name id]} #?(:clj (when (enc/and* thread incl-thread?) (af " thread: " (vf thread)))) ; {:keys [group name id]}