Enable Lettuce instrumentation by default
This commit is contained in:
parent
37a54b5776
commit
46428dc6a3
|
@ -16,11 +16,6 @@ public class LettuceAsyncCommandsInstrumentation extends Instrumenter.Default {
|
|||
super("lettuce", "lettuce-5-async");
|
||||
}
|
||||
|
||||
@Override
|
||||
protected boolean defaultEnabled() {
|
||||
return false;
|
||||
}
|
||||
|
||||
@Override
|
||||
public ElementMatcher typeMatcher() {
|
||||
return named("io.lettuce.core.AbstractRedisAsyncCommands");
|
||||
|
|
|
@ -23,11 +23,6 @@ public final class LettuceClientInstrumentation extends Instrumenter.Default {
|
|||
super("lettuce");
|
||||
}
|
||||
|
||||
@Override
|
||||
protected boolean defaultEnabled() {
|
||||
return false;
|
||||
}
|
||||
|
||||
@Override
|
||||
public ElementMatcher typeMatcher() {
|
||||
return named("io.lettuce.core.RedisClient");
|
||||
|
|
|
@ -18,11 +18,6 @@ public class LettuceReactiveCommandsInstrumentation extends Instrumenter.Default
|
|||
super("lettuce", "lettuce-5-rx");
|
||||
}
|
||||
|
||||
@Override
|
||||
protected boolean defaultEnabled() {
|
||||
return false;
|
||||
}
|
||||
|
||||
@Override
|
||||
public ElementMatcher typeMatcher() {
|
||||
return named("io.lettuce.core.AbstractRedisReactiveCommands");
|
||||
|
|
|
@ -27,11 +27,6 @@ import static datadog.trace.agent.test.ListWriterAssert.assertTraces
|
|||
import static datadog.trace.instrumentation.lettuce.LettuceInstrumentationUtil.AGENT_CRASHING_COMMAND_PREFIX
|
||||
|
||||
class LettuceAsyncClientTest extends AgentTestRunner {
|
||||
|
||||
static {
|
||||
System.setProperty("dd.integration.lettuce.enabled", "true")
|
||||
}
|
||||
|
||||
public static final String HOST = "127.0.0.1"
|
||||
public static final int PORT = TestUtils.randomOpenPort()
|
||||
public static final int INCORRECT_PORT = TestUtils.randomOpenPort()
|
||||
|
|
|
@ -14,11 +14,6 @@ import static datadog.trace.agent.test.ListWriterAssert.assertTraces
|
|||
import static datadog.trace.instrumentation.lettuce.LettuceInstrumentationUtil.AGENT_CRASHING_COMMAND_PREFIX
|
||||
|
||||
class LettuceReactiveClientTest extends AgentTestRunner {
|
||||
|
||||
static {
|
||||
System.setProperty("dd.integration.lettuce.enabled", "true")
|
||||
}
|
||||
|
||||
public static final String HOST = "127.0.0.1"
|
||||
public static final int PORT = TestUtils.randomOpenPort()
|
||||
public static final int DB_INDEX = 0
|
||||
|
@ -60,7 +55,7 @@ class LettuceReactiveClientTest extends AgentTestRunner {
|
|||
connection.close()
|
||||
redisServer.stop()
|
||||
}
|
||||
|
||||
|
||||
def "set command with subscribe on a defined consumer"() {
|
||||
setup:
|
||||
def conds = new AsyncConditions()
|
||||
|
|
|
@ -14,11 +14,6 @@ import static datadog.trace.agent.test.ListWriterAssert.assertTraces
|
|||
import static datadog.trace.instrumentation.lettuce.LettuceInstrumentationUtil.AGENT_CRASHING_COMMAND_PREFIX
|
||||
|
||||
class LettuceSyncClientTest extends AgentTestRunner {
|
||||
|
||||
static {
|
||||
System.setProperty("dd.integration.lettuce.enabled", "true")
|
||||
}
|
||||
|
||||
public static final String HOST = "127.0.0.1"
|
||||
public static final int PORT = TestUtils.randomOpenPort()
|
||||
public static final int INCORRECT_PORT = TestUtils.randomOpenPort()
|
||||
|
|
Loading…
Reference in New Issue