Enable gRPC instrumentation by default.
This commit is contained in:
parent
6cb9e0360d
commit
43e8c70098
|
@ -42,11 +42,6 @@ public class GrpcClientBuilderInstrumentation extends Instrumenter.Default {
|
||||||
isMethod().and(named("build")), AddInterceptorAdvice.class.getName());
|
isMethod().and(named("build")), AddInterceptorAdvice.class.getName());
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
protected boolean defaultEnabled() {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
public static class AddInterceptorAdvice {
|
public static class AddInterceptorAdvice {
|
||||||
|
|
||||||
@Advice.OnMethodEnter(suppress = Throwable.class)
|
@Advice.OnMethodEnter(suppress = Throwable.class)
|
||||||
|
|
|
@ -40,11 +40,6 @@ public class GrpcServerBuilderInstrumentation extends Instrumenter.Default {
|
||||||
isMethod().and(named("build")), AddInterceptorAdvice.class.getName());
|
isMethod().and(named("build")), AddInterceptorAdvice.class.getName());
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
protected boolean defaultEnabled() {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
public static class AddInterceptorAdvice {
|
public static class AddInterceptorAdvice {
|
||||||
|
|
||||||
@Advice.OnMethodEnter(suppress = Throwable.class)
|
@Advice.OnMethodEnter(suppress = Throwable.class)
|
||||||
|
|
|
@ -16,9 +16,6 @@ import java.util.concurrent.TimeUnit
|
||||||
import java.util.concurrent.atomic.AtomicReference
|
import java.util.concurrent.atomic.AtomicReference
|
||||||
|
|
||||||
class GrpcStreamingTest extends AgentTestRunner {
|
class GrpcStreamingTest extends AgentTestRunner {
|
||||||
static {
|
|
||||||
System.setProperty("dd.integration.grpc.enabled", "true")
|
|
||||||
}
|
|
||||||
|
|
||||||
def "test conversation #name"() {
|
def "test conversation #name"() {
|
||||||
setup:
|
setup:
|
||||||
|
|
|
@ -16,9 +16,6 @@ import io.opentracing.tag.Tags
|
||||||
import java.util.concurrent.TimeUnit
|
import java.util.concurrent.TimeUnit
|
||||||
|
|
||||||
class GrpcTest extends AgentTestRunner {
|
class GrpcTest extends AgentTestRunner {
|
||||||
static {
|
|
||||||
System.setProperty("dd.integration.grpc.enabled", "true")
|
|
||||||
}
|
|
||||||
|
|
||||||
def "test request-response"() {
|
def "test request-response"() {
|
||||||
setup:
|
setup:
|
||||||
|
|
Loading…
Reference in New Issue