Module: Rails::Instrumentation::ActiveJobSubscriber
- Includes:
- Subscriber
- Defined in:
- lib/rails/instrumentation/subscribers/active_job_subscriber.rb
Constant Summary collapse
- EVENT_NAMESPACE =
'active_job'.freeze
- EVENTS =
%w[ enqueue_at enqueue perform_start perform ].freeze
Class Method Summary collapse
- .enqueue(event) ⇒ Object
- .enqueue_at(event) ⇒ Object
- .perform(event) ⇒ Object
- .perform_start(event) ⇒ Object
Methods included from Subscriber
Class Method Details
.enqueue(event) ⇒ Object
25 26 27 28 29 30 31 32 |
# File 'lib/rails/instrumentation/subscribers/active_job_subscriber.rb', line 25 def enqueue(event) = { 'adapter' => event.payload[:adapter], 'job' => event.payload[:job] } Utils.trace_notification(event: event, tags: ) end |
.enqueue_at(event) ⇒ Object
16 17 18 19 20 21 22 23 |
# File 'lib/rails/instrumentation/subscribers/active_job_subscriber.rb', line 16 def enqueue_at(event) = { 'adapter' => event.payload[:adapter], 'job' => event.payload[:job] } Utils.trace_notification(event: event, tags: ) end |
.perform(event) ⇒ Object
43 44 45 46 47 48 49 50 |
# File 'lib/rails/instrumentation/subscribers/active_job_subscriber.rb', line 43 def perform(event) = { 'adapter' => event.payload[:adapter], 'job' => event.payload[:job] } Utils.trace_notification(event: event, tags: ) end |
.perform_start(event) ⇒ Object
34 35 36 37 38 39 40 41 |
# File 'lib/rails/instrumentation/subscribers/active_job_subscriber.rb', line 34 def perform_start(event) = { 'adapter' => event.payload[:adapter], 'job' => event.payload[:job] } Utils.trace_notification(event: event, tags: ) end |