Module: AtomicSidekiq::Web

Defined in:
lib/atomic_sidekiq/web.rb

Constant Summary collapse

VIEW_PATH = 
File.expand_path("../../web/views", __dir__)

Class Method Summary collapse

Class Method Details

.register_inflight(app) ⇒ Object 



10
11
12
13
14
15
16
17
18
19
20
21
22
23
 
# File 'lib/atomic_sidekiq/web.rb', line 10

def self.register_inflight(app)
  app.get "/in-flight" do
    @jobs = AtomicSidekiq::InFlightQueue.new.list
    @total_size = @jobs.count
    @count = (params[:count] || 25).to_i
    @current_page = (params[:page] || 1).to_i

    start_idx = (@current_page - 1) * @count
    end_idx = (@current_page * @count) - 1
    @jobs = @jobs[start_idx..end_idx]

    erb File.read(File.join(VIEW_PATH, "in_flight.erb"))
  end
end

.register_recovered(app) ⇒ Object 



25
26
27
28
29
30
31
32
 
# File 'lib/atomic_sidekiq/web.rb', line 25

def self.register_recovered(app)
  app.get "/recovered" do
    @queues = AtomicSidekiq::RecoveredStats.new.stats_by_queue
    @jobs = AtomicSidekiq::RecoveredStats.new.stats_by_job

    erb File.read(File.join(VIEW_PATH, "recovered.erb"))
  end
end

.registered(app) ⇒ Object 



5
6
7
8
 
# File 'lib/atomic_sidekiq/web.rb', line 5

def self.registered(app)
  register_inflight(app)
  register_recovered(app)
end