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

Returns a new instance of ChainTracker.



19
20
21
 
# File 'lib/netuitive_rails_agent/sidekiq.rb', line 19

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

Instance Attribute Details

#interaction ⇒ Object

Returns the value of attribute interaction.



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

def interaction
  @interaction
end

Instance Method Details

#call(worker, item, queue) ⇒ Object 



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

def call(worker, item, queue)
  NetuitiveRailsAgent::ErrorLogger.guard('error during sidekiq ChainTracker') do
    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)
  end
  yield
end