class GemeraldBeanstalk::Jobs
Attributes
total_jobs[R]
Public Class Methods
new(*)
click to toggle source
Calls superclass method
# File lib/gemerald_beanstalk/jobs.rb, line 29 def initialize(*) @total_jobs = 0 super end
Public Instance Methods
counts_by_state()
click to toggle source
# File lib/gemerald_beanstalk/jobs.rb, line 4 def counts_by_state job_stats = { 'current-jobs-urgent' => 0, 'current-jobs-ready' => 0, 'current-jobs-reserved' => 0, 'current-jobs-delayed' => 0, 'current-jobs-buried' => 0, } self.compact.each do |job| state = job.state job_stats["current-jobs-#{state}"] += 1 job_stats['current-jobs-urgent'] += 1 if state == :ready && job.priority < 1024 end return job_stats end
enqueue(job)
click to toggle source
# File lib/gemerald_beanstalk/jobs.rb, line 22 def enqueue(job) @total_jobs += 1 push(job) return self end
next_id()
click to toggle source
# File lib/gemerald_beanstalk/jobs.rb, line 35 def next_id return @total_jobs + 1 end