Sha256: 2d2e3ef3415cf5822987809d858382039123c8e3c31b65bfda8ffb8de7d416b0
Contents?: true
Size: 1.25 KB
Versions: 9
Compression:
Stored size: 1.25 KB
Contents
# frozen_string_literal: true
module PrometheusExporter::Server
class HutchCollector < TypeCollector
def type
"hutch"
end
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_hutch_metrics
@hutch_job_duration_seconds.observe(obj["duration"], labels)
@hutch_jobs_total.observe(1, labels)
@hutch_failed_jobs_total.observe(1, labels) if !obj["success"]
end
def metrics
if @hutch_jobs_total
[@hutch_job_duration_seconds, @hutch_jobs_total, @hutch_failed_jobs_total]
else
[]
end
end
protected
def ensure_hutch_metrics
if !@hutch_jobs_total
@hutch_job_duration_seconds = PrometheusExporter::Metric::Counter.new(
"hutch_job_duration_seconds", "Total time spent in hutch jobs.")
@hutch_jobs_total = PrometheusExporter::Metric::Counter.new(
"hutch_jobs_total", "Total number of hutch jobs executed.")
@hutch_failed_jobs_total = PrometheusExporter::Metric::Counter.new(
"hutch_failed_jobs_total", "Total number failed hutch jobs executed.")
end
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems