From 6c37e25a8dcd9faf036d2670a05fcf99e0a90517 Mon Sep 17 00:00:00 2001 From: Ola Aunronning Date: Wed, 15 Feb 2023 12:02:57 +0100 Subject: docproc metrics as gauges instead of counters --- docproc/src/main/java/com/yahoo/docproc/Call.java | 13 +++++-------- 1 file changed, 5 insertions(+), 8 deletions(-) diff --git a/docproc/src/main/java/com/yahoo/docproc/Call.java b/docproc/src/main/java/com/yahoo/docproc/Call.java index 3612e676ac9..8fafa0fd059 100644 --- a/docproc/src/main/java/com/yahoo/docproc/Call.java +++ b/docproc/src/main/java/com/yahoo/docproc/Call.java @@ -154,8 +154,8 @@ public class Call implements Cloneable { schemaMapProcessing(processing); long startTime = SystemTimer.INSTANCE.milliTime(); DocumentProcessor.Progress retval = processor.process(processing); - incrementProcTime(SystemTimer.INSTANCE.milliTime() - startTime); - incrementDocs(numDocs); + long procTime = SystemTimer.INSTANCE.milliTime() - startTime; + updateMetrics(procTime, numDocs); return retval; } finally { unwrapSchemaMapping(processing); @@ -166,12 +166,9 @@ public class Call implements Cloneable { return "call to class " + processor.getClass().getName() + " (id: " + getDocumentProcessorId() + ")"; } - private void incrementDocs(long increment) { - metric.add(PROC_DOC_COUNT_METRIC_NAME, increment, metricContext); - } - - private void incrementProcTime(long increment) { - metric.add(PROC_TIME_METRIC_NAME, increment, metricContext); + private void updateMetrics(long procTime, long documentCount) { + metric.set(PROC_DOC_COUNT_METRIC_NAME, documentCount, metricContext); + metric.set(PROC_TIME_METRIC_NAME, procTime, metricContext); } } -- cgit v1.2.3