Skip to content

Commit

Permalink
Enable Armeria server instrumentation notFound() test (open-telemetry…
Browse files Browse the repository at this point in the history
  • Loading branch information
Mateusz Rzeszutek authored and RashmiRam committed May 23, 2022
1 parent 2250a9a commit 1082611
Show file tree
Hide file tree
Showing 5 changed files with 5 additions and 22 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
* SPDX-License-Identifier: Apache-2.0
*/

package io.opentelemetry.instrumentation.armeria.v1_3.internal;
package io.opentelemetry.instrumentation.armeria.v1_3;

import com.linecorp.armeria.common.RequestContext;
import com.linecorp.armeria.common.logging.RequestLog;
Expand All @@ -13,7 +13,7 @@
import java.net.SocketAddress;
import javax.annotation.Nullable;

public final class ArmeriaNetClientAttributesExtractor
final class ArmeriaNetClientAttributesExtractor
extends InetSocketAddressNetClientAttributesExtractor<RequestContext, RequestLog> {

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@
* SPDX-License-Identifier: Apache-2.0
*/

package io.opentelemetry.instrumentation.armeria.v1_3.internal;
package io.opentelemetry.instrumentation.armeria.v1_3;

import com.linecorp.armeria.common.RequestContext;
import com.linecorp.armeria.common.logging.RequestLog;
Expand All @@ -13,7 +13,7 @@
import java.net.SocketAddress;
import javax.annotation.Nullable;

public final class ArmeriaNetServerAttributesExtractor
final class ArmeriaNetServerAttributesExtractor
extends InetSocketAddressNetServerAttributesExtractor<RequestContext, RequestLog> {

@Override
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -21,8 +21,6 @@
import io.opentelemetry.instrumentation.api.instrumenter.http.HttpServerMetrics;
import io.opentelemetry.instrumentation.api.instrumenter.http.HttpSpanNameExtractor;
import io.opentelemetry.instrumentation.api.instrumenter.http.HttpSpanStatusExtractor;
import io.opentelemetry.instrumentation.armeria.v1_3.internal.ArmeriaNetClientAttributesExtractor;
import io.opentelemetry.instrumentation.armeria.v1_3.internal.ArmeriaNetServerAttributesExtractor;
import io.opentelemetry.semconv.trace.attributes.SemanticAttributes;
import java.util.ArrayList;
import java.util.List;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,6 @@

import com.linecorp.armeria.common.HttpRequest;
import com.linecorp.armeria.common.HttpResponse;
import com.linecorp.armeria.common.HttpStatus;
import com.linecorp.armeria.common.logging.RequestLog;
import com.linecorp.armeria.server.HttpService;
import com.linecorp.armeria.server.ServiceRequestContext;
Expand Down Expand Up @@ -36,15 +35,7 @@ public HttpResponse serve(ServiceRequestContext ctx, HttpRequest req) throws Exc
if (span.isRecording()) {
ctx.log()
.whenComplete()
.thenAccept(
log -> {
if (log.responseHeaders().status().equals(HttpStatus.NOT_FOUND)) {
// Assume a not-found request was not served. The route we use by default will be
// some fallback like `/*` which is not as useful as the requested path.
span.updateName(ctx.path());
}
instrumenter.end(context, ctx, log, log.responseCause());
});
.thenAccept(log -> instrumenter.end(context, ctx, log, log.responseCause()));
}

try (Scope ignored = context.makeCurrent()) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -50,12 +50,6 @@ abstract class AbstractArmeriaHttpServerTest extends HttpServerTest<Server> {
]
}

@Override
boolean testNotFound() {
// currently span name is /notFound which indicates it won't be low-cardinality
false
}

@Override
Server startServer(int port) {
ServerBuilder sb = Server.builder()
Expand Down

0 comments on commit 1082611

Please sign in to comment.