3pp-mirror/penpot
1
0
Fork 0
mirror of https://github.com/penpot/penpot.git synced 2025-05-20 03:36:11 +02:00
Code Issues Projects Releases Packages Wiki Activity

🐛 Proper prefix rpc metrics.

Browse source
This commit is contained in:
Andrey Antukh 2021-01-15 15:39:27 +01:00
parent 32de3d9f1d
commit 83f43af36e
1 changed files with 6 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

14
backend/src/app/rpc.clj
View file

@ -52,17 +52,15 @@
(fn? (:transform-response mdata)) ((:transform-response mdata) request)))) (fn? (:transform-response mdata)) ((:transform-response mdata) request))))
(defn- wrap-impl (defn- wrap-impl
[f mdata cfg] [f mdata cfg prefix]
(let [mreg (get-in cfg [:metrics :registry]) (let [mreg (get-in cfg [:metrics :registry])
mobj (mtx/create mobj (mtx/create
{:name (-> (str "rpc_" (::sv/name mdata) "_response_millis") {:name (-> (str "rpc_" (name prefix) "_" (::sv/name mdata) "_response_millis")
(str/replace "-" "_")) (str/replace "-" "_"))
:registry mreg :registry mreg
:type :summary :type :summary
:help (str/format "Service '%s' response time in milliseconds." (::sv/name mdata))}) :help (str/format "Service '%s' response time in milliseconds." (::sv/name mdata))})
f (mtx/wrap-summary f mobj) f (mtx/wrap-summary f mobj)
spec (or (::sv/spec mdata) (s/spec any?))] spec (or (::sv/spec mdata) (s/spec any?))]
(log/debugf "Registering '%s' command to rpc service." (::sv/name mdata)) (log/debugf "Registering '%s' command to rpc service." (::sv/name mdata))
@ -74,10 +72,10 @@
(f cfg (us/conform spec params))))) (f cfg (us/conform spec params)))))
(defn- process-method (defn- process-method
[cfg vfn] [cfg prefix vfn]
(let [mdata (meta vfn)] (let [mdata (meta vfn)]
[(keyword (::sv/name mdata)) [(keyword (::sv/name mdata))
(wrap-impl (deref vfn) mdata cfg)])) (wrap-impl (deref vfn) mdata cfg prefix)]))
(defn- resolve-query-methods (defn- resolve-query-methods
[cfg] [cfg]
@ -88,7 +86,7 @@
'app.rpc.queries.profile 'app.rpc.queries.profile
'app.rpc.queries.recent-files 'app.rpc.queries.recent-files
'app.rpc.queries.viewer) 'app.rpc.queries.viewer)
(map (partial process-method cfg)) (map (partial process-method cfg :query))
(into {}))) (into {})))
(defn- resolve-mutation-methods (defn- resolve-mutation-methods
@ -102,7 +100,7 @@
'app.rpc.mutations.viewer 'app.rpc.mutations.viewer
'app.rpc.mutations.teams 'app.rpc.mutations.teams
'app.rpc.mutations.verify-token) 'app.rpc.mutations.verify-token)
(map (partial process-method cfg)) (map (partial process-method cfg :mutation))
(into {}))) (into {})))
(s/def ::storage some?) (s/def ::storage some?)