Contents

require "resque"

module Ddr::Jobs
  class Queue

    attr_reader :name

    def initialize(name)
      @name = name
    end

    def size
      Resque.size(name)
    end

    # @return [Array<Hash>] jobs in the queue, optionally filtered by type,
    #   start position, and count.
    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

  end
end

Version data entries

67 entries across 67 versions & 1 rubygems

Version	Path
ddr-models-2.6.2	lib/ddr/jobs/queue.rb
ddr-models-2.6.1	lib/ddr/jobs/queue.rb
ddr-models-2.6.0	lib/ddr/jobs/queue.rb
ddr-models-2.6.0.rc4	lib/ddr/jobs/queue.rb
ddr-models-2.6.0.rc3	lib/ddr/jobs/queue.rb
ddr-models-2.6.0.rc2	lib/ddr/jobs/queue.rb
ddr-models-2.6.0.rc1	lib/ddr/jobs/queue.rb
ddr-models-2.5.3	lib/ddr/jobs/queue.rb
ddr-models-2.5.2	lib/ddr/jobs/queue.rb
ddr-models-2.5.1	lib/ddr/jobs/queue.rb
ddr-models-2.5.0	lib/ddr/jobs/queue.rb
ddr-models-2.5.0.rc1	lib/ddr/jobs/queue.rb
ddr-models-2.4.16	lib/ddr/jobs/queue.rb
ddr-models-2.4.15	lib/ddr/jobs/queue.rb
ddr-models-2.4.14	lib/ddr/jobs/queue.rb
ddr-models-2.4.13	lib/ddr/jobs/queue.rb
ddr-models-2.4.12	lib/ddr/jobs/queue.rb
ddr-models-2.4.11	lib/ddr/jobs/queue.rb
ddr-models-3.0.8	lib/ddr/jobs/queue.rb
ddr-models-3.0.7	lib/ddr/jobs/queue.rb