Class: Nunes::Subscribers::ActiveJob

Inherits:
Nunes::Subscriber show all
Defined in:
lib/nunes/subscribers/active_job.rb

Constant Summary collapse

Pattern =

Private

/\.active_job\Z/

Constants inherited from Nunes::Subscriber

Nunes::Subscriber::BANG, Nunes::Subscriber::DOT

Instance Attribute Summary

Attributes inherited from Nunes::Subscriber

#adapter

Class Method Summary collapse

Instance Method Summary collapse

Methods inherited from Nunes::Subscriber

#call, #increment, #initialize, subscribe, #timing

Constructor Details

This class inherits a constructor from Nunes::Subscriber

Class Method Details

.pattern ⇒ Object

Private: The namespace for events to subscribe to.



10
11
12
 
# File 'lib/nunes/subscribers/active_job.rb', line 10

def self.pattern
  Pattern
end

Instance Method Details

#enqueue(start, ending, transaction_id, payload) ⇒ Object 



21
22
23
24
 
# File 'lib/nunes/subscribers/active_job.rb', line 21

def enqueue(start, ending, transaction_id, payload)
  job = ::Nunes.class_to_metric(payload[:job].class)
  increment "active_job.#{job}.enqueue"
end

#perform(start, ending, transaction_id, payload) ⇒ Object 



14
15
16
17
18
19
 
# File 'lib/nunes/subscribers/active_job.rb', line 14

def perform(start, ending, transaction_id, payload)
  runtime = ((ending - start) * 1_000).round
  job = ::Nunes.class_to_metric(payload[:job].class)

  timing "active_job.#{job}.perform", runtime
end