From 578b08a3a88cfa931aedcc4b1590d63881025d0b Mon Sep 17 00:00:00 2001 From: clsv Date: Thu, 5 Oct 2023 02:46:39 +0300 Subject: [PATCH] add prom metrics init --- cron/cron.go | 11 +++++++++++ main.go | 2 +- 2 files changed, 12 insertions(+), 1 deletion(-) diff --git a/cron/cron.go b/cron/cron.go index 512dc5c..cce33df 100644 --- a/cron/cron.go +++ b/cron/cron.go @@ -268,6 +268,17 @@ func StartJob( ) } +func InitJobPromMetrics( + job *crontab.Job, + promMetrics *prometheus_metrics.PrometheusMetrics, +) { + promMetrics.CronsCurrentlyRunningGauge.With(jobPromLabels(job)).Add(0) + promMetrics.CronsExecCounter.With(jobPromLabels(job)).Add(0) + promMetrics.CronsSuccessCounter.With(jobPromLabels(job)).Add(0) + promMetrics.CronsFailCounter.With(jobPromLabels(job)).Add(0) + promMetrics.CronsDeadlineExceededCounter.With(jobPromLabels(job)).Add(0) +} + func jobPromLabels(job *crontab.Job) prometheus.Labels { return prometheus.Labels{ "position": fmt.Sprintf("%d", job.Position), diff --git a/main.go b/main.go index a8f1990..6d3048b 100644 --- a/main.go +++ b/main.go @@ -146,7 +146,7 @@ func main() { "job.command": job.Command, "job.position": job.Position, }) - + cron.InitJobPromMetrics(job, &promMetrics) cron.StartJob(&wg, tab.Context, job, exitCtx, cronLogger, *overlapping, *passthroughLogs, &promMetrics) }