From 6b910d0b7582bfe5b669320108439c83a618f94b Mon Sep 17 00:00:00 2001 From: Henrique Chehad Date: Wed, 21 Sep 2016 20:25:37 -0300 Subject: [PATCH 1/2] added wait time total and reserved memory metrics --- api/runner/runner.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/api/runner/runner.go b/api/runner/runner.go index 321d17129..7f3b4d079 100644 --- a/api/runner/runner.go +++ b/api/runner/runner.go @@ -102,7 +102,8 @@ func (r *Runner) queueHandler() { } metricBaseName := fmt.Sprintf("run.%s.", task.cfg.AppName) - r.ml.LogTime(task.ctx, metricBaseName+"waittime", waitTime) + r.ml.LogTime(task.ctx, metricBaseName+"wait_time", waitTime) + r.ml.LogTime(task.ctx, "run.wait_time", waitTime) if timedOut { // Send to a signal to this task saying it cannot run @@ -198,6 +199,7 @@ func (r *Runner) Run(ctx context.Context, cfg *Config) (drivers.RunResult, error } r.addUsedMem(-1 * int64(cfg.Memory)) + r.ml.LogGauge(ctx, metricBaseName+"reserved_memory", int(r.usedMem)) if result.Status() == "success" { r.ml.LogCount(ctx, metricBaseName+"succeeded", 1) From ba3f0b360b3a4c018f83816fbacf84c82b232e7a Mon Sep 17 00:00:00 2001 From: Henrique Chehad Date: Wed, 21 Sep 2016 22:35:07 -0300 Subject: [PATCH 2/2] removed "reserved_memory" metric --- api/runner/runner.go | 1 - 1 file changed, 1 deletion(-) diff --git a/api/runner/runner.go b/api/runner/runner.go index 7f3b4d079..2f8a6bd93 100644 --- a/api/runner/runner.go +++ b/api/runner/runner.go @@ -199,7 +199,6 @@ func (r *Runner) Run(ctx context.Context, cfg *Config) (drivers.RunResult, error } r.addUsedMem(-1 * int64(cfg.Memory)) - r.ml.LogGauge(ctx, metricBaseName+"reserved_memory", int(r.usedMem)) if result.Status() == "success" { r.ml.LogCount(ctx, metricBaseName+"succeeded", 1)