Skip to content

HTTPS clone URL

Subversion checkout URL

You can clone with HTTPS or Subversion.

Download ZIP
Browse files

Merge pull request #37 from heroku/remove-railgun

no more railgun: moved to l2met
  • Loading branch information...
commit 9cf4e2d4c93f8d682e8af413807c08d99496db1e 2 parents ec1d05b + 506a11d
@technomancy technomancy authored
Showing with 0 additions and 304 deletions.
  1. +0 −304 src/pulse/def.clj
View
304 src/pulse/def.clj
@@ -677,310 +677,6 @@
(fn [evt] [(:instance_id evt) (:drain_id evt)])
:drain_delivered))
-; railgun
-
-(defn railgun? [evt]
- (k? evt :railgun))
-
-(defstat railgun-running-count
- (last-count
- (fn [evt] (and (railgun? evt) (k? evt :heartbeat)))
- :instance_id
- (constantly true)
- 40))
-
-(defstat railgun-denied-count
- (last-count
- (fn [evt] (and (railgun? evt) (k? evt :stats) (emit? evt)))
- :instance_id
- :deny
- 40))
-
-(defstat railgun-packed-count
- (last-count
- (fn [evt] (and (railgun? evt) (k? evt :stats) (emit? evt)))
- :instance_id
- :packed
- 40))
-
-(defstat railgun-loaded-count
- (last-count
- (fn [evt] (and (railgun? evt) (k? evt :stats) (emit? evt)))
- :instance_id
- (fn [evt] (kv? evt :load_status "loaded"))
- 40))
-
-(defstat railgun-critical-count
- (last-count
- (fn [evt] (and (railgun? evt) (k? evt :stats) (emit? evt)))
- :instance_id
- (fn [evt] (kv? evt :load_status "critical"))
- 40))
-
-(defstat railgun-accepting-count
- (last-count
- (fn [evt] (and (railgun? evt) (k? evt :stats) (emit? evt)))
- :instance_id
- (fn [evt] (kv? evt :run_factor 1))
- 40))
-
-(defstat railgun-load-avg-15m-mean
- (last-mean 90
- (fn [evt] (and (railgun? evt) (k? evt :check_load_status) (kv? evt :at "report")))
- :instance_id
- :load_avg_fifteen))
-
-(defstat railgun-ps-running-total-last
- (last-sum
- (fn [evt] (and (railgun? evt) (k? evt :counts) (kv? evt :key "total")))
- :instance_id
- :num))
-
-(defn last-sum-process-type [t]
- (last-sum
- (fn [evt] (and (railgun? evt) (k? evt :counts) (kv? evt :key "process_type") (kv? evt :process_type t)))
- :instance_id
- :num))
-
-(defstat railgun-ps-running-web-last
- (last-sum-process-type "web"))
-
-(defstat railgun-ps-running-worker-last
- (last-sum-process-type "worker"))
-
-(defstat railgun-ps-running-clock-last
- (last-sum-process-type "clock"))
-
-(defstat railgun-ps-running-console-last
- (last-sum-process-type "console"))
-
-(defstat railgun-ps-running-rake-last
- (last-sum-process-type "rake"))
-
-(defstat railgun-ps-running-other-last
- (last-sum-process-type "other"))
-
-(defstat railgun-runs-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :ps_watch) (k? evt :ps_run) (kv? evt :at "start")))))
-
-(defstat railgun-returns-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :ps_watch) (k? evt :ps_run) (kv? evt :at "exit")))))
-
-(defstat railgun-kills-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :ps_terminate) (k? evt :term_pid) (start? evt)))))
-
-(defstat railgun-subscribes-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :converge_queues) (kv? evt :at "subscribe")))))
-
-(defstat railgun-unsubscribes-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :converge_queues) (kv? evt :at "unsubscribe")))))
-
-(defstat railgun-status-batches-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :publish_batch_status) (finish? evt)))))
-
-(defstat railgun-gcs-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :gc_one) (finish? evt)))))
-
-(defstat railgun-kill-time-mean
- (mean 70
- (fn [evt] (and (railgun? evt) (k? evt :kill) (finish? evt)))
- :elapsed))
-
-(defstat railgun-save-time-mean
- (mean 70
- (fn [evt] (and (railgun? evt) (k? evt :save_slug) (finish? evt)))
- :elapsed))
-
-(defstat railgun-unpack-time-mean
- (mean 70
- (fn [evt] (and (railgun? evt) (k? evt :unpack_slug) (kv? evt :slug_url true) (finish? evt)))
- :elapsed))
-
-(defstat railgun-setup-time-mean
- (mean 70
- (fn [evt] (and (railgun? evt) (k? evt :start_boot) (finish? evt)))
- :age))
-
-(defstat railgun-launch-time-mean
- (mean 70
- (fn [evt] (and (railgun? evt) (k? evt :monitor_boot) (kv? evt :at "responsive")))
- :age))
-
-(defstat railgun-status-batch-time-mean
- (mean 70
- (fn [evt] (and (railgun? evt) (k? evt :publish_batch_status) (finish? evt)))
- :elapsed))
-
-(defstat railgun-gc-time-mean
- (mean 70
- (fn [evt] (and (railgun? evt) (k? evt :gc_one) (finish? evt)))
- :elapsed))
-
-(defstat railgun-s3-requests-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :save_slug_attempt) (start? evt)))))
-
-(defstat railgun-s3-errors-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :save_slug_attempt) (error? evt)))))
-
-(defstat railgun-s3-time-mean
- (mean 70
- (fn [evt] (and (railgun? evt) (k? evt :save_slug_attempt) (finish? evt)))
- :elapsed))
-
-(defstat railgun-slug-download-fails-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :save_slug) (kv? evt :at "failed")))))
-
-(defstat railgun-s3-canary-requests-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :check_s3) (start? evt)))))
-
-(defstat railgun-s3-canary-errors-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :check_s3) (error? evt)))))
-
-(defstat railgun-s3-canary-time-mean
- (mean 70
- (fn [evt] (and (railgun? evt) (k? evt :check_s3) (finish? evt)))
- :elapsed))
-
-(defstat railgun-r10-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :monitor_boot) (kv? evt :at "timeout")))))
-
-(defstat railgun-r11-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :monitor_boot) (kv? evt :at "bad_bind")))))
-
-(defstat railgun-r12-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :kill_pids) (kv? evt :at "timeout")))))
-
-(defstat railgun-r10-apps-per-minute
- (per-minute-unique
- (fn [evt] (and (railgun? evt) (k? evt :monitor_boot) (kv? evt :at "timeout")))
- :app_id))
-
-(defstat railgun-r11-apps-per-minute
- (per-minute-unique
- (fn [evt] (and (railgun? evt) (k? evt :monitor_boot) (kv? evt :at "bad_bind")))
- :app_id))
-
-(defstat railgun-r12-apps-per-minute
- (per-minute-unique
- (fn [evt] (and (railgun? evt) (k? evt :kill_pids) (kv? evt :at "timeout")))
- :app_id))
-
-(defstat railgun-r14-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :check_usage)
- (kv? evt :resource "memory") (kv? evt :at "warn")))))
-
-(defstat railgun-r15-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :check_usage)
- (kv? evt :resource "memory") (kv? evt :at "kill")))))
-
-(defstat railgun-r16-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :sighup_user_pids) (kv? evt :at "detached")))))
-
-(defstat railgun-r17-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :check_usage)
- (kv? evt :resource "cpu") (kv? evt :at "warn")))))
-
-(defstat railgun-r18-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :check_usage)
- (kv? evt :resource "cpu") (kv? evt :at "kill")))))
-
-(defstat railgun-r14-apps-per-minute
- (per-minute-unique
- (fn [evt] (and (railgun? evt) (k? evt :check_usage)
- (kv? evt :resource "memory") (kv? evt :at "warn")))
- :app_id))
-
-(defstat railgun-r15-apps-per-minute
- (per-minute-unique
- (fn [evt] (and (railgun? evt) (k? evt :check_usage)
- (kv? evt :resource "memory") (kv? evt :at "kill")))
- :app_id))
-
-(defstat railgun-r17-apps-per-minute
- (per-minute-unique
- (fn [evt] (and (railgun? evt) (k? evt :check_usage)
- (kv? evt :resource "cpu") (kv? evt :at "warn")))
- :app_id))
-
-(defstat railgun-r18-apps-per-minute
- (per-minute-unique
- (fn [evt] (and (railgun? evt) (k? evt :check_usage)
- (kv? evt :resource "cpu") (kv? evt :at "kill")))
- :app_id))
-
-(defstat railgun-inits-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :init_railgun) (start? evt)))))
-
-(defstat railgun-traps-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :trap)))))
-
-(defstat railgun-exits-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :init_railgun) (finish? evt)))))
-
-(defstat railgun-unhandled-exceptions-per-minute
- (per-minute
- (fn [evt] (and (k? evt :railgun) (k? evt :exception)
- (not (k? evt :site)) (not (k? evt :reraise))
- (not (k? evt :trapping))))))
-
-(defstat railgun-pings-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :server) (k? evt :request) (finish? evt)))))
-
-(defstat railgun-heartbeats-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :heartbeat)))))
-
-(defstat railgun-runtime-bus-publishes-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :bus) (k? evt :queue) (kv? evt :at "publish")))))
-
-(defstat railgun-runtime-bus-processing-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :bus) (k? evt :queue) (kv? evt :at "processing")))))
-
-(defstat railgun-runtime-bus-expired-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :bus) (k? evt :message) (kv? evt :status "expired")))))
-
-(defstat railgun-runtime-bus-invalid-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :bus) (k? evt :message) (kv? evt :status "invalid")))))
-
-(defstat railgun-runtime-bus-failed-pushes-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :bus) (k? evt :pool) (k? evt :skipping_failed_connection)))))
-
-(defstat railgun-runtime-bus-failed-lpops-per-minute
- (per-minute
- (fn [evt] (and (railgun? evt) (k? evt :bus) (k? evt :pool) (kv? evt :operation "blpop_single") (kv? evt :at "exception")))))
-
-(defstat railgun-events-per-second
- (per-second railgun?))
-
; internal
(defstat-single pulse-events-per-second
Please sign in to comment.
Something went wrong with that request. Please try again.