aboutsummaryrefslogtreecommitdiffstats
path: root/docproc
diff options
context:
space:
mode:
authorOla Aunronning <olaa@yahooinc.com>2023-02-10 14:10:48 +0100
committerOla Aunronning <olaa@yahooinc.com>2023-02-10 14:10:48 +0100
commit4bc45a0eb891883f0a7c4ad63d1cedc4b65ebd19 (patch)
tree4836234bd0792f8b93351a90810884e4aa80d35a /docproc
parentf62bb48baf715609606faa82a6119012b8a727de (diff)
Rename docproc metrics
Diffstat (limited to 'docproc')
-rw-r--r--docproc/src/main/java/com/yahoo/docproc/Call.java20
1 files changed, 11 insertions, 9 deletions
diff --git a/docproc/src/main/java/com/yahoo/docproc/Call.java b/docproc/src/main/java/com/yahoo/docproc/Call.java
index 440935ef494..3612e676ac9 100644
--- a/docproc/src/main/java/com/yahoo/docproc/Call.java
+++ b/docproc/src/main/java/com/yahoo/docproc/Call.java
@@ -12,8 +12,10 @@ import com.yahoo.document.DocumentPut;
import com.yahoo.document.DocumentUpdate;
import com.yahoo.jdisc.Metric;
import com.yahoo.concurrent.SystemTimer;
+import com.yahoo.metrics.ContainerMetrics;
import java.util.List;
+import java.util.Map;
/**
* A document processor to call - an item on a {@link com.yahoo.docproc.CallStack}.
@@ -24,9 +26,10 @@ import java.util.List;
public class Call implements Cloneable {
private final DocumentProcessor processor;
- private final String docCounterName;
- private final String procTimeCounterName;
+ private final String PROC_TIME_METRIC_NAME = ContainerMetrics.DOCPROC_PROC_TIME.baseName();
+ private final String PROC_DOC_COUNT_METRIC_NAME = ContainerMetrics.DOCPROC_DOCUMENTS.baseName();
private final Metric metric;
+ private final Metric.Context metricContext;
public Call(DocumentProcessor processor) {
this(processor, new NullMetric());
@@ -45,12 +48,11 @@ public class Call implements Cloneable {
this.processor = processor;
if (chainName == null)
chainName = "";
- chainName = chainName.replaceAll("[^\\p{Alnum}]", "_");
- docCounterName = "docprocessor_" + chainName + "_" +
- getDocumentProcessorId().stringValue().replaceAll("[^\\p{Alnum}]", "_") + "_documents";
- procTimeCounterName = "docprocessor_" + chainName + "_" +
- getDocumentProcessorId().stringValue().replaceAll("[^\\p{Alnum}]", "_") + "_proctime";
this.metric = metric;
+ this.metricContext = metric.createContext(Map.of(
+ "chain", chainName,
+ "docproc", getDocumentProcessorId().stringValue()
+ ));
}
@Override
@@ -165,11 +167,11 @@ public class Call implements Cloneable {
}
private void incrementDocs(long increment) {
- metric.add(docCounterName, increment, null);
+ metric.add(PROC_DOC_COUNT_METRIC_NAME, increment, metricContext);
}
private void incrementProcTime(long increment) {
- metric.add(procTimeCounterName, increment, null);
+ metric.add(PROC_TIME_METRIC_NAME, increment, metricContext);
}
}