class Ddr::Jobs::Queue

Attributes

name[R]

Public Class Methods

new(name) click to toggle source
# File lib/ddr/jobs/queue.rb, line 8
def initialize(name)
  @name = name
end

Public Instance Methods

jobs(type: nil, start: 0, count: nil) click to toggle source

@return [Array<Hash>] jobs in the queue, optionally filtered by type,

start position, and count.
# File lib/ddr/jobs/queue.rb, line 18
def jobs(type: nil, start: 0, count: nil)
  jobs = Resque.peek(name, start, count || size)
  if type
    jobs.select! { |job| job["class"] == type.to_s }
  end
  jobs
end
size() click to toggle source
# File lib/ddr/jobs/queue.rb, line 12
def size
  Resque.size(name)
end