aboutsummaryrefslogtreecommitdiffstats
path: root/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java
diff options
context:
space:
mode:
authorvalerijf <valerijf@yahoo-inc.com>2017-05-12 09:28:06 +0200
committervalerijf <valerijf@yahoo-inc.com>2017-05-12 09:40:38 +0200
commit09be694323fbe1955c345e183d807d7c60e80c51 (patch)
tree71dd6c36587e0d256b6c57ec05a7faf17abbaaba /vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java
parentbd6bb3b7518e3da3869d1f45741c0cd86795308a (diff)
Code review fixes
Diffstat (limited to 'vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java')
-rw-r--r--vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java13
1 files changed, 7 insertions, 6 deletions
diff --git a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java
index 218d1779bb5..dbcb55cfd06 100644
--- a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java
+++ b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/OperationHandlerImpl.java
@@ -16,7 +16,7 @@ import com.yahoo.documentapi.VisitorParameters;
import com.yahoo.documentapi.VisitorSession;
import com.yahoo.documentapi.messagebus.MessageBusSyncSession;
import com.yahoo.documentapi.messagebus.protocol.DocumentProtocol;
-import com.yahoo.documentapi.metrics.DocumentApiMetricsHelper;
+import com.yahoo.documentapi.metrics.DocumentApiMetrics;
import com.yahoo.documentapi.metrics.DocumentOperationStatus;
import com.yahoo.documentapi.metrics.DocumentOperationType;
import com.yahoo.messagebus.StaticThrottlePolicy;
@@ -32,6 +32,7 @@ import org.apache.commons.lang3.exception.ExceptionUtils;
import java.io.ByteArrayOutputStream;
import java.nio.charset.StandardCharsets;
+import java.time.Instant;
import java.util.List;
import java.util.Optional;
import java.util.Set;
@@ -49,7 +50,7 @@ public class OperationHandlerImpl implements OperationHandler {
public static final int VISIT_TIMEOUT_MS = 120000;
private final DocumentAccess documentAccess;
- private final DocumentApiMetricsHelper metricsHelper;
+ private final DocumentApiMetrics metricsHelper;
private final ClusterEnumerator clusterEnumerator;
private static final class SyncSessionFactory extends ResourceFactory<SyncSession> {
@@ -73,7 +74,7 @@ public class OperationHandlerImpl implements OperationHandler {
this.documentAccess = documentAccess;
this.clusterEnumerator = clusterEnumerator;
syncSessions = new ConcurrentResourcePool<>(new SyncSessionFactory(documentAccess));
- metricsHelper = new DocumentApiMetricsHelper(metricReceiver, "documentV1");
+ metricsHelper = new DocumentApiMetrics(metricReceiver, "documentV1");
}
@Override
@@ -188,7 +189,7 @@ public class OperationHandlerImpl implements OperationHandler {
SyncSession syncSession = syncSessions.alloc();
Response response;
try {
- long startTime = System.currentTimeMillis();
+ Instant startTime = Instant.now();
DocumentPut put = new DocumentPut(data.getDocument());
put.setCondition(data.getCondition());
setRoute(syncSession, route);
@@ -212,7 +213,7 @@ public class OperationHandlerImpl implements OperationHandler {
SyncSession syncSession = syncSessions.alloc();
Response response;
try {
- long startTime = System.currentTimeMillis();
+ Instant startTime = Instant.now();
setRoute(syncSession, route);
syncSession.update(data.getDocumentUpdate());
metricsHelper.reportSuccessful(DocumentOperationType.UPDATE, startTime);
@@ -234,7 +235,7 @@ public class OperationHandlerImpl implements OperationHandler {
SyncSession syncSession = syncSessions.alloc();
Response response;
try {
- long startTime = System.currentTimeMillis();
+ Instant startTime = Instant.now();
DocumentId id = new DocumentId(restUri.generateFullId());
DocumentRemove documentRemove = new DocumentRemove(id);
setRoute(syncSession, route);