8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
|
# File 'lib/prometheus_exporter/server/delayed_job_collector.rb', line 8
def collect(obj)
default_labels = { job_name: obj['name'] }
custom_labels = obj['custom_labels']
labels = custom_labels.nil? ? default_labels : default_labels.merge(custom_labels)
ensure_delayed_job_metrics
@delayed_job_duration_seconds.observe(obj["duration"], labels)
@delayed_jobs_total.observe(1, labels)
@delayed_failed_jobs_total.observe(1, labels) if !obj["success"]
@delayed_jobs_max_attempts_reached_total.observe(1) if obj["attempts"] >= obj["max_attempts"]
@delayed_job_duration_seconds_summary.observe(obj["duration"])
@delayed_job_duration_seconds_summary.observe(obj["duration"], status: "success") if obj["success"]
@delayed_job_duration_seconds_summary.observe(obj["duration"], status: "failed") if !obj["success"]
@delayed_job_attempts_summary.observe(obj["attempts"]) if obj["success"]
end
|