Class: NetuitiveRailsAgent::SidekiqTracker::ChainTracker

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

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ ChainTracker 



17
18
19
 
# File 'lib/netuitive_rails_agent/sidekiq.rb', line 17

def initialize
  @interaction = NetuitiveRailsAgent::ApiInteraction.new
end

Instance Attribute Details

#interaction ⇒ Object

Returns the value of attribute interaction.



16
17
18
 
# File 'lib/netuitive_rails_agent/sidekiq.rb', line 16

def interaction
  @interaction
end

Instance Method Details

#call(worker, item, queue) ⇒ Object 



21
22
23
24
25
26
27
28
29
30
31
32
33
 
# File 'lib/netuitive_rails_agent/sidekiq.rb', line 21

def call(worker, item, queue)
  begin
    klass = item['wrapped'.freeze] || worker.class.to_s
    queue = item['queue']
    NetuitiveRailsAgent::NetuitiveLogger.log.debug "sidekiq job tracked. queue: #{queue}, class: #{klass}"
    interaction.aggregate_metric("sidekiq.#{klass}.job.count", 1)
    interaction.aggregate_metric("sidekiq.#{queue}.job.count", 1)
    interaction.aggregate_metric("sidekiq.#{queue}.#{klass}.job.count", 1)
  rescue => e
    NetuitiveRailsAgent::NetuitiveLogger.log.error "exception during sidekiq chain tracking: message:#{e.message} backtrace:#{e.backtrace}"
  end
  yield
end