module Resque::Plugins::Statsd
Constants
- VERSION
Public Instance Methods
after_enqueue_statsd(*args)
click to toggle source
# File lib/resque/plugins/statsd.rb, line 4 def after_enqueue_statsd(*args) StatsdHelper.statsd.increment("queues.#{@queue}.enqueued") StatsdHelper.statsd.increment("jobs.#{self.name}.enqueued") StatsdHelper.statsd.increment("total.enqueued") rescue SocketError => se # Common cause of this is failure of getaddrinfo (I.E. can't route to # statsd server or some such). This may happen in development, when # your net connection isn't in a good way, for example. # # Ignoring this because we don't want unreachability of statsd to # impair the ability of an app to actually operate. end
after_perform_statsd(*args)
click to toggle source
# File lib/resque/plugins/statsd.rb, line 30 def after_perform_statsd(*args) StatsdHelper.statsd.increment("queues.#{@queue}.finished") StatsdHelper.statsd.increment("jobs.#{self.name}.finished") StatsdHelper.statsd.increment("total.finished") rescue SocketError => se # Common cause of this is failure of getaddrinfo (I.E. can't route to # statsd server or some such). This may happen in development, when # your net connection isn't in a good way, for example. # # Ignoring this because we don't want unreachability of statsd to # impair the ability of an app to actually operate. end
around_perform_statsd(*args) { || ... }
click to toggle source
# File lib/resque/plugins/statsd.rb, line 56 def around_perform_statsd(*args) # We don't want to swallow a SocketError if it didn't actually come # from our attempts to talk to statsd. failure_is_in_app = true StatsdHelper.statsd.time("queues.#{@queue}.processed") do StatsdHelper.statsd.time("jobs.#{self.name}.processed") do yield failure_is_in_app = false end end rescue SocketError => se # Common cause of this is failure of getaddrinfo (I.E. can't route to # statsd server or some such). This may happen in development, when # your net connection isn't in a good way, for example. # # Ignoring this iff it's statsd-related because we don't want # unreachability of statsd to impair the ability of an app to actually # operate. raise se if(failure_is_in_app) end
before_perform_statsd(*args)
click to toggle source
# File lib/resque/plugins/statsd.rb, line 17 def before_perform_statsd(*args) StatsdHelper.statsd.increment("queues.#{@queue}.started") StatsdHelper.statsd.increment("jobs.#{self.name}.started") StatsdHelper.statsd.increment("total.started") rescue SocketError => se # Common cause of this is failure of getaddrinfo (I.E. can't route to # statsd server or some such). This may happen in development, when # your net connection isn't in a good way, for example. # # Ignoring this because we don't want unreachability of statsd to # impair the ability of an app to actually operate. end
on_failure_statsd(*args)
click to toggle source
# File lib/resque/plugins/statsd.rb, line 43 def on_failure_statsd(*args) StatsdHelper.statsd.increment("queues.#{@queue}.failed") StatsdHelper.statsd.increment("jobs.#{self.name}.failed") StatsdHelper.statsd.increment("total.failed") rescue SocketError => se # Common cause of this is failure of getaddrinfo (I.E. can't route to # statsd server or some such). This may happen in development, when # your net connection isn't in a good way, for example. # # Ignoring this because we don't want unreachability of statsd to # impair the ability of an app to actually operate. end