From 7d1f9efb51626a24cb427d56a1f359f7eb98a13a Mon Sep 17 00:00:00 2001 From: Jorge Quilcate Otoya Date: Tue, 29 Oct 2019 12:33:47 +0100 Subject: [PATCH] Update dependencies (#2892) --- pom.xml | 11 ++++------- .../zipkin2/server/internal/ZipkinQueryApiV2.java | 10 ++++++++++ 2 files changed, 14 insertions(+), 7 deletions(-) diff --git a/pom.xml b/pom.xml index 14ebcc2dccf..c1dde0b7da3 100755 --- a/pom.xml +++ b/pom.xml @@ -49,7 +49,7 @@ com.linecorp.armeria - 0.94.0 + 0.95.0 28.1-jre @@ -73,15 +73,12 @@ 4.12 5.5.2 - 2.0.2 - - 2.23.4 + 2.0.4 + 2.28.2 3.13.2 4.0.1 1.3 - 1.12.2 + 1.12.3 1.7 1.18 diff --git a/zipkin-server/src/main/java/zipkin2/server/internal/ZipkinQueryApiV2.java b/zipkin-server/src/main/java/zipkin2/server/internal/ZipkinQueryApiV2.java index e0bef3c1d43..ab430b9139a 100644 --- a/zipkin-server/src/main/java/zipkin2/server/internal/ZipkinQueryApiV2.java +++ b/zipkin-server/src/main/java/zipkin2/server/internal/ZipkinQueryApiV2.java @@ -19,6 +19,7 @@ import com.linecorp.armeria.common.MediaType; import com.linecorp.armeria.common.ResponseHeaders; import com.linecorp.armeria.common.ResponseHeadersBuilder; +import com.linecorp.armeria.server.annotation.Blocking; import com.linecorp.armeria.server.annotation.Default; import com.linecorp.armeria.server.annotation.ExceptionHandler; import com.linecorp.armeria.server.annotation.Get; @@ -76,6 +77,7 @@ public class ZipkinQueryApiV2 { } @Get("/api/v2/dependencies") + @Blocking public AggregatedHttpResponse getDependencies( @Param("endTs") long endTs, @Param("lookback") Optional lookback) throws IOException { @@ -85,6 +87,7 @@ public AggregatedHttpResponse getDependencies( } @Get("/api/v2/services") + @Blocking public AggregatedHttpResponse getServiceNames() throws IOException { List serviceNames = storage.serviceAndSpanNames().getServiceNames().execute(); serviceCount = serviceNames.size(); @@ -92,6 +95,7 @@ public AggregatedHttpResponse getServiceNames() throws IOException { } @Get("/api/v2/spans") + @Blocking public AggregatedHttpResponse getSpanNames(@Param("serviceName") String serviceName) throws IOException { List spanNames = storage.serviceAndSpanNames().getSpanNames(serviceName).execute(); @@ -99,6 +103,7 @@ public AggregatedHttpResponse getSpanNames(@Param("serviceName") String serviceN } @Get("/api/v2/remoteServices") + @Blocking public AggregatedHttpResponse getRemoteServiceNames(@Param("serviceName") String serviceName) throws IOException { List remoteServiceNames = @@ -107,6 +112,7 @@ public AggregatedHttpResponse getRemoteServiceNames(@Param("serviceName") String } @Get("/api/v2/traces") + @Blocking public AggregatedHttpResponse getTraces( @Param("serviceName") Optional serviceName, @Param("remoteServiceName") Optional remoteServiceName, @@ -136,6 +142,7 @@ public AggregatedHttpResponse getTraces( } @Get("/api/v2/trace/{traceId}") + @Blocking public AggregatedHttpResponse getTrace(@Param("traceId") String traceId) throws IOException { traceId = Span.normalizeTraceId(traceId); List trace = storage.traces().getTrace(traceId).execute(); @@ -146,6 +153,7 @@ public AggregatedHttpResponse getTrace(@Param("traceId") String traceId) throws } @Get("/api/v2/traceMany") + @Blocking public AggregatedHttpResponse getTraces(@Param("traceIds") String traceIds) throws IOException { if (traceIds.isEmpty()) { return AggregatedHttpResponse.of(BAD_REQUEST, ANY_TEXT_TYPE, "traceIds parameter is empty"); @@ -185,11 +193,13 @@ static AggregatedHttpResponse jsonResponse(byte[] body) { }; @Get("/api/v2/autocompleteKeys") + @Blocking public AggregatedHttpResponse getAutocompleteKeys() { return maybeCacheNames(true, autocompleteKeys); } @Get("/api/v2/autocompleteValues") + @Blocking public AggregatedHttpResponse getAutocompleteValues(@Param("key") String key) throws IOException { List values = storage.autocompleteTags().getValues(key).execute(); return maybeCacheNames(values.size() > 3, values);