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