Module: Resque::Plugins::JobStats

Includes:
Duration, Enqueued, Failed, History, MeasuredHook, Performed, Timeseries::Enqueued, Timeseries::Performed
Defined in:
lib/resque-job-stats/server.rb,
lib/resque/plugins/job_stats.rb,
lib/resque/plugins/job_stats/failed.rb,
lib/resque/plugins/job_stats/history.rb,
lib/resque/plugins/job_stats/version.rb,
lib/resque/plugins/job_stats/duration.rb,
lib/resque/plugins/job_stats/enqueued.rb,
lib/resque/plugins/job_stats/performed.rb,
lib/resque/plugins/job_stats/statistic.rb,
lib/resque/plugins/job_stats/timeseries.rb,
lib/resque/plugins/job_stats/measured_hook.rb

Defined Under Namespace

Modules: Duration, Enqueued, Failed, History, MeasuredHook, Performed, Server, Timeseries Classes: Statistic

Constant Summary collapse

VERSION =
'0.4.2'

Class Method Summary collapse

Methods included from History

#around_perform_job_stats_history, #histories_recordable, #histories_recorded, #job_histories, #jobs_history_key, #reset_job_histories

Methods included from Timeseries::Performed

#after_perform_job_stats_timeseries, #performed_per_hour, #performed_per_minute

Methods included from Timeseries::Common

#timestamp

Methods included from MeasuredHook

included, #inherited

Methods included from Timeseries::Enqueued

#after_enqueue_job_stats_timeseries, #queued_per_hour, #queued_per_minute

Methods included from Duration

#around_perform_job_stats_duration, #durations_recorded, #job_durations, #job_rolling_avg, #jobs_duration_key, #longest_job, #reset_job_durations

Methods included from Failed

#jobs_failed, #jobs_failed=, #jobs_failed_key, #on_failure_job_stats_failed

Methods included from Enqueued

#after_enqueue_job_stats_enqueued, #jobs_enqueued, #jobs_enqueued=, #jobs_enqueued_key

Methods included from Performed

#after_perform_job_stats_performed, #jobs_performed, #jobs_performed=, #jobs_performed_key

Class Method Details

.add_measured_job(name) ⇒ Object



23
24
25
# File 'lib/resque/plugins/job_stats.rb', line 23

def self.add_measured_job(name)
  Resque.redis.sadd("stats:jobs", name)
end

.measured_jobsObject



31
32
33
# File 'lib/resque/plugins/job_stats.rb', line 31

def self.measured_jobs
  Resque.redis.smembers("stats:jobs").collect { |c| Object.const_get(c) rescue nil }.compact
end

.rem_measured_job(name) ⇒ Object



27
28
29
# File 'lib/resque/plugins/job_stats.rb', line 27

def self.rem_measured_job(name)
  Resque.redis.srem("stats:jobs", name)
end