Class: BrainzLab::Rails::Collectors::ActiveJob

Inherits:
Base
  • Object
show all
Defined in:
lib/brainzlab/rails/collectors/active_job.rb

Overview

Collects Active Job events for background job observability Routes to Nerve for specialized job monitoring + other products

Instance Attribute Summary

Attributes inherited from Base

#configuration

Instance Method Summary collapse

Methods inherited from Base

#initialize

Constructor Details

This class inherits a constructor from BrainzLab::Rails::Collectors::Base

Instance Method Details

#process(event_data) ⇒ Object 



9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/brainzlab/rails/collectors/active_job.rb', line 9

def process(event_data)
  case event_data[:name]
  when 'enqueue.active_job'
    handle_enqueue(event_data)
  when 'enqueue_at.active_job'
    handle_enqueue_at(event_data)
  when 'enqueue_all.active_job'
    handle_enqueue_all(event_data)
  when 'enqueue_retry.active_job'
    handle_enqueue_retry(event_data)
  when 'perform_start.active_job'
    handle_perform_start(event_data)
  when 'perform.active_job'
    handle_perform(event_data)
  when 'retry_stopped.active_job'
    handle_retry_stopped(event_data)
  when 'discard.active_job'
    handle_discard(event_data)
  end
end