Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with
or
.
Download ZIP
Browse files

add logplex stats

  • Loading branch information...
commit 92350d7771f7025176497ff6e828aa037cdb67dd 1 parent e1df759
@jkvor jkvor authored
Showing with 17 additions and 1 deletion.
  1. +14 −0 src/pulse/def.clj
  2. +3 −1 src/pulse/web.clj
View
14 src/pulse/def.clj
@@ -519,6 +519,18 @@
:instance_id
:ports))
+(defstat logplex-msg-processed
+ (last-sum
+ (fn [evt] (and (cloud? evt) (k? evt :logplex_stats) (k? evt :message_processed)))
+ :instance_id
+ :message_processed))
+
+(defstat logplex-drain-delivered
+ (last-sum
+ (fn [evt] (and (cloud? evt) (k? evt :logplex_stats) (k? evt :drain_delivered)))
+ :instance_id
+ :drain_delivered))
+
; railgun
(defn railgun? [evt]
@@ -1416,6 +1428,8 @@
hermes-catastrophic-redis-lookups-per-minute
hermes-processes-last
hermes-ports-last
+ logplex-msg-processed
+ logplex-drain-delivered
; railgun
railgun-running-count
View
4 src/pulse/web.clj
@@ -133,7 +133,9 @@
["hermes slow rd/min" "hermes-slow-redis-lookups-per-minute"]
["hermes cat rd/min" "hermes-catastrophic-redis-lookups-per-minute"]
["hermes processes" "hermes-processes-last"]
- ["hermes ports" "hermes-ports-last"]]])
+ ["hermes ports" "hermes-ports-last"]]
+ [["logplex processed" "logplex-msg-processed"]
+ ["logplex drained" "logplex-drain-delivered"]]])
(def graphs-railgun
[[["railgun running" "railgun-running-count"]
Please sign in to comment.
Something went wrong with that request. Please try again.