Class: Sideq::Queue

Inherits:
Object
  • Object
show all
Defined in:
lib/sideq/queue.rb

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(name) ⇒ Queue

Returns a new instance of Queue.



21
22
23
24
 
# File 'lib/sideq/queue.rb', line 21

def initialize( name )
  @name = name
  @queue = Sidekiq::Queue.new( name )
end

Instance Attribute Details

#name ⇒ Object (readonly)

Returns the value of attribute name.



3
4
5
 
# File 'lib/sideq/queue.rb', line 3

def name
  @name
end

#queue ⇒ Object (readonly)

Returns the value of attribute queue.



3
4
5
 
# File 'lib/sideq/queue.rb', line 3

def queue
  @queue
end

Class Method Details

.overview ⇒ Object 



5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
 
# File 'lib/sideq/queue.rb', line 5

def self.overview
  retry_set = Sidekiq::RetrySet.new
  dead_set = Sidekiq::DeadSet.new

  ary = Sidekiq::Queue.all.each_with_object( [] ) do |queue, memo|
    memo << sprintf( "%-30s %5d (%8.2f s latency), %spaused", 
                    queue.name,
                    queue.size,
                    queue.latency,
                    queue.paused? ? '' : "not " )
  end
  ary << sprintf( "%-30s %5d", "retry", retry_set.size )
  ary << sprintf( "%-30s %5d", "dead", dead_set.size )
  ary.join( "\n" )
end

Instance Method Details

#clear ⇒ Object 



53
54
55
 
# File 'lib/sideq/queue.rb', line 53

def clear
  puts "Queue #{name}: Deleted #{queue.clear.first} entries"
end

#delete_entries(job_ids) ⇒ Object 



44
45
46
47
48
49
50
51
 
# File 'lib/sideq/queue.rb', line 44

def delete_entries( job_ids )
  deleted = 0
  each_job( job_ids ) do |job|
    job.delete
    puts "#{job_id}: deleted"
    deleted += 1
  end
end

#details(job_ids) ⇒ Object 



37
38
39
40
41
42
 
# File 'lib/sideq/queue.rb', line 37

def details( job_ids )
  queue.each_with_object( [] ) do |job, memo|
    next unless job_ids.include?( job.jid )
    memo << job_details( job )
  end.join( "\n\n" )
end

#to_s ⇒ Object 



26
27
28
29
30
31
32
33
34
35
 
# File 'lib/sideq/queue.rb', line 26

def to_s
  queue.each_with_object( [ "Queue entries: #{queue.size}" ] ) do |job, memo|
    memo << sprintf( "%24s - %19s\n  %-77s\n  e: %19s - lat: %19s\n",
                      job.jid,
                      job.created_at.strftime( "%F %T" ),
                      job.display_class,
                      job.enqueued_at.strftime( "%F %T" ),
                      job.latency )
  end.join( "\n" )
end