Class: Pique::JobAdapter

Inherits:
Object
  • Object
show all
Defined in:
lib/pique/adapters/sidekiq.rb

Instance Method Summary collapse

Constructor Details

#initialize(job) ⇒ JobAdapter

Returns a new instance of JobAdapter.



3
4
5
 
# File 'lib/pique/adapters/sidekiq.rb', line 3

def initialize(job)
  @job = job
end

Instance Method Details

#arguments ⇒ Object 



30
31
32
 
# File 'lib/pique/adapters/sidekiq.rb', line 30

def arguments
  @job['args'] || @job['arguments']
end

#created_at ⇒ Object 



34
35
36
 
# File 'lib/pique/adapters/sidekiq.rb', line 34

def created_at
  Time.at(@job['created_at']).utc.iso8601
end

#enqueued_at ⇒ Object 



38
39
40
 
# File 'lib/pique/adapters/sidekiq.rb', line 38

def enqueued_at
  @job['enqueued_at'].present? ? Time.at(@job['enqueued_at']).utc.iso8601 : nil
end

#job_class ⇒ Object 



26
27
28
 
# File 'lib/pique/adapters/sidekiq.rb', line 26

def job_class
  @job['class'] || @job['job_class']
end

#job_id ⇒ Object 



18
19
20
 
# File 'lib/pique/adapters/sidekiq.rb', line 18

def job_id
  @job['jid'] || @job['job_id']
end

#queue_name ⇒ Object 



22
23
24
 
# File 'lib/pique/adapters/sidekiq.rb', line 22

def queue_name
  @job['queue'] || @job['queue_name']
end

#to_json ⇒ Object 



7
8
9
10
11
12
13
14
15
16
 
# File 'lib/pique/adapters/sidekiq.rb', line 7

def to_json
  {
    job_id: job_id,
    queue_name: queue_name,
    job_class: job_class,
    arguments: arguments.map(&:to_s),
    created_at: created_at,
    enqueued_at: enqueued_at
  }.to_json
end