diff options
author | Ola Aunronning <olaa@yahooinc.com> | 2023-02-15 12:02:57 +0100 |
---|---|---|
committer | Ola Aunronning <olaa@yahooinc.com> | 2023-02-15 12:02:57 +0100 |
commit | 6c37e25a8dcd9faf036d2670a05fcf99e0a90517 (patch) | |
tree | f371e6422b9444c981a6c834a7db0facedd48aff /docproc | |
parent | 0e4828fb1fbc5c6a3a5d6680b4526d024f9debd5 (diff) |
docproc metrics as gauges instead of counters
Diffstat (limited to 'docproc')
-rw-r--r-- | docproc/src/main/java/com/yahoo/docproc/Call.java | 13 |
1 files 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); } } |