diff options
author | jonmv <venstad@gmail.com> | 2022-08-11 14:22:52 +0200 |
---|---|---|
committer | jonmv <venstad@gmail.com> | 2022-08-11 14:22:52 +0200 |
commit | 1559a5a3df5edc438a9f6315a3240a7668e336fa (patch) | |
tree | bd5b6828b63c02fa825b538aebc3ef5517722cf5 /vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java | |
parent | 5fec3608e404237ac006b59a4acf41bcfb1353dc (diff) |
Disallow dryRun at other paths, and update abi spec
Diffstat (limited to 'vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java')
-rw-r--r-- | vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java index 26ef157c5ae..c72bc1ef4c5 100644 --- a/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java +++ b/vespaclient-container-plugin/src/main/java/com/yahoo/document/restapi/resource/DocumentV1ApiHandler.java @@ -362,6 +362,7 @@ public class DocumentV1ApiHandler extends AbstractRequestHandler { } private ContentChannel getDocuments(HttpRequest request, DocumentPath path, ResponseHandler handler) { + disallow(request, DRY_RUN); enqueueAndDispatch(request, handler, () -> { boolean streamed = getProperty(request, STREAM, booleanParser).orElse(false); VisitorParameters parameters = parseGetParameters(request, path, streamed); @@ -374,6 +375,7 @@ public class DocumentV1ApiHandler extends AbstractRequestHandler { } private ContentChannel postDocuments(HttpRequest request, DocumentPath path, ResponseHandler handler) { + disallow(request, DRY_RUN); enqueueAndDispatch(request, handler, () -> { StorageCluster destination = resolveCluster(Optional.of(requireProperty(request, DESTINATION_CLUSTER)), clusters); VisitorParameters parameters = parseParameters(request, path); @@ -388,6 +390,7 @@ public class DocumentV1ApiHandler extends AbstractRequestHandler { } private ContentChannel putDocuments(HttpRequest request, DocumentPath path, ResponseHandler handler) { + disallow(request, DRY_RUN); return new ForwardingContentChannel(in -> { enqueueAndDispatch(request, handler, () -> { StorageCluster cluster = resolveCluster(Optional.of(requireProperty(request, CLUSTER)), clusters); @@ -406,6 +409,7 @@ public class DocumentV1ApiHandler extends AbstractRequestHandler { } private ContentChannel deleteDocuments(HttpRequest request, DocumentPath path, ResponseHandler handler) { + disallow(request, DRY_RUN); enqueueAndDispatch(request, handler, () -> { VisitorParameters parameters = parseParameters(request, path); parameters.setFieldSet(DocIdOnly.NAME); @@ -420,6 +424,7 @@ public class DocumentV1ApiHandler extends AbstractRequestHandler { } private ContentChannel getDocument(HttpRequest request, DocumentPath path, ResponseHandler handler) { + disallow(request, DRY_RUN); enqueueAndDispatch(request, handler, () -> { DocumentOperationParameters rawParameters = parametersFromRequest(request, CLUSTER, FIELD_SET); if (rawParameters.fieldSet().isEmpty()) |