Module: Appsignal::Hooks::ActiveJobHook::ActiveJobHelpers Private

Defined in:
lib/appsignal/hooks/active_job.rb

This module is part of a private API. You should avoid using this module if possible, as it may be removed or be changed in the future.

Constant Summary collapse

ACTION_MAILER_CLASSES =

This constant is part of a private API. You should avoid using this constant if possible, as it may be removed or be changed in the future. 

[
  "ActionMailer::DeliveryJob",
  "ActionMailer::Parameterized::DeliveryJob",
  "ActionMailer::MailDeliveryJob"
].freeze

Class Method Summary collapse

Class Method Details

.action_name(job) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



94
95
96
97
98
99
100
101
 
# File 'lib/appsignal/hooks/active_job.rb', line 94

def self.action_name(job)
  case job["job_class"]
  when *ACTION_MAILER_CLASSES
    job["arguments"][0..1].join("#")
  else
    "#{job["job_class"]}#perform"
  end
end

.increment_counter(key, value, tags = {}) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



134
135
136
 
# File 'lib/appsignal/hooks/active_job.rb', line 134

def self.increment_counter(key, value, tags = {})
  Appsignal.increment_counter "active_job_#{key}", value, tags
end

.metrics_for(job) ⇒ Array

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns an array of metrics with tags used to report the job metrics

If job ONLY has a queue, it will return queue_job_count with tags. If job has a queue AND priority, it will ALSO return queue_priority_job_count with tags.

Returns:

  • (Array) —

    Array of metrics with tags to report.



110
111
112
113
114
115
116
117
118
119
120
121
122
123
 
# File 'lib/appsignal/hooks/active_job.rb', line 110

def self.metrics_for(job)
  tags = { :queue => job["queue_name"] }
  metrics = [["queue_job_count", tags]]

  priority = job["priority"]
  if priority
    metrics << [
      "queue_priority_job_count",
      tags.merge(:priority => priority)
    ]
  end

  metrics
end

.transaction_tags_for(job) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future. 



125
126
127
128
129
130
131
132
 
# File 'lib/appsignal/hooks/active_job.rb', line 125

def self.transaction_tags_for(job)
  tags = {}
  queue = job["queue_name"]
  tags[:queue] = queue if queue
  priority = job["priority"]
  tags[:priority] = priority if priority
  tags
end