Enable instrumentation by default and rev version.
This commit is contained in:
parent
8001c82527
commit
71eb71e53e
|
@ -38,7 +38,7 @@ dependencies {
|
||||||
}
|
}
|
||||||
|
|
||||||
test {
|
test {
|
||||||
jvmArgs "-Ddd.writer.type=ListWriter", "-Ddd.service.name=java-app"
|
jvmArgs "-Ddd.writer.type=LogWriter", "-Ddd.service.name=java-app"
|
||||||
jvmArgs "-Ddatadog.slf4j.simpleLogger.defaultLogLevel=debug"
|
jvmArgs "-Ddatadog.slf4j.simpleLogger.defaultLogLevel=debug"
|
||||||
jvmArgs "-Dorg.slf4j.simpleLogger.defaultLogLevel=debug"
|
jvmArgs "-Dorg.slf4j.simpleLogger.defaultLogLevel=debug"
|
||||||
|
|
||||||
|
|
|
@ -29,11 +29,6 @@ public final class JaxRsAnnotationsInstrumentation extends Instrumenter.Configur
|
||||||
super("jax-rs", "jaxrs", "jax-rs-annotations");
|
super("jax-rs", "jaxrs", "jax-rs-annotations");
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
protected boolean defaultEnabled() {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
protected AgentBuilder apply(final AgentBuilder agentBuilder) {
|
protected AgentBuilder apply(final AgentBuilder agentBuilder) {
|
||||||
return agentBuilder
|
return agentBuilder
|
||||||
|
|
|
@ -7,11 +7,7 @@ import spock.lang.Unroll
|
||||||
import javax.ws.rs.*
|
import javax.ws.rs.*
|
||||||
|
|
||||||
@Timeout(1)
|
@Timeout(1)
|
||||||
class JaxRsInstrumentationTest extends AgentTestRunner {
|
class JaxRsAnnotationsInstrumentationTest extends AgentTestRunner {
|
||||||
|
|
||||||
static {
|
|
||||||
System.setProperty("dd.integration.jax-rs.enabled", "true")
|
|
||||||
}
|
|
||||||
|
|
||||||
@Unroll
|
@Unroll
|
||||||
def "span named '#resourceName' from annotations on class"() {
|
def "span named '#resourceName' from annotations on class"() {
|
|
@ -7,10 +7,6 @@ import spock.lang.Timeout
|
||||||
@Timeout(5)
|
@Timeout(5)
|
||||||
class JerseyTest extends AgentTestRunner {
|
class JerseyTest extends AgentTestRunner {
|
||||||
|
|
||||||
static {
|
|
||||||
System.setProperty("dd.integration.jax-rs.enabled", "true")
|
|
||||||
}
|
|
||||||
|
|
||||||
@Shared
|
@Shared
|
||||||
@ClassRule
|
@ClassRule
|
||||||
ResourceTestRule resources = ResourceTestRule.builder().addResource(new TestResource()).build()
|
ResourceTestRule resources = ResourceTestRule.builder().addResource(new TestResource()).build()
|
||||||
|
|
|
@ -30,11 +30,6 @@ public final class JedisInstrumentation extends Instrumenter.Configurable {
|
||||||
super(SERVICE_NAME);
|
super(SERVICE_NAME);
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
protected boolean defaultEnabled() {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public AgentBuilder apply(final AgentBuilder agentBuilder) {
|
public AgentBuilder apply(final AgentBuilder agentBuilder) {
|
||||||
return agentBuilder
|
return agentBuilder
|
||||||
|
|
|
@ -13,10 +13,6 @@ class JedisClientTest extends AgentTestRunner {
|
||||||
|
|
||||||
public static final int PORT = 6399
|
public static final int PORT = 6399
|
||||||
|
|
||||||
static {
|
|
||||||
System.setProperty("dd.integration.redis.enabled", "true")
|
|
||||||
}
|
|
||||||
|
|
||||||
@Shared
|
@Shared
|
||||||
RedisServer redisServer = RedisServer.builder()
|
RedisServer redisServer = RedisServer.builder()
|
||||||
// bind to localhost to avoid firewall popup
|
// bind to localhost to avoid firewall popup
|
||||||
|
|
|
@ -43,11 +43,6 @@ public final class KafkaConsumerInstrumentation extends Instrumenter.Configurabl
|
||||||
super("kafka");
|
super("kafka");
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
protected boolean defaultEnabled() {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public AgentBuilder apply(final AgentBuilder agentBuilder) {
|
public AgentBuilder apply(final AgentBuilder agentBuilder) {
|
||||||
return agentBuilder
|
return agentBuilder
|
||||||
|
|
|
@ -40,11 +40,6 @@ public final class KafkaProducerInstrumentation extends Instrumenter.Configurabl
|
||||||
super("kafka");
|
super("kafka");
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
protected boolean defaultEnabled() {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public AgentBuilder apply(final AgentBuilder agentBuilder) {
|
public AgentBuilder apply(final AgentBuilder agentBuilder) {
|
||||||
return agentBuilder
|
return agentBuilder
|
||||||
|
|
|
@ -20,10 +20,6 @@ import java.util.concurrent.TimeUnit
|
||||||
class KafkaClientTest extends AgentTestRunner {
|
class KafkaClientTest extends AgentTestRunner {
|
||||||
static final SHARED_TOPIC = "shared.topic"
|
static final SHARED_TOPIC = "shared.topic"
|
||||||
|
|
||||||
static {
|
|
||||||
System.setProperty("dd.integration.kafka.enabled", "true")
|
|
||||||
}
|
|
||||||
|
|
||||||
@Shared
|
@Shared
|
||||||
@ClassRule
|
@ClassRule
|
||||||
KafkaEmbedded embeddedKafka = new KafkaEmbedded(1, true, SHARED_TOPIC)
|
KafkaEmbedded embeddedKafka = new KafkaEmbedded(1, true, SHARED_TOPIC)
|
||||||
|
|
|
@ -44,11 +44,6 @@ public class KafkaStreamsProcessorInstrumentation {
|
||||||
super("kafka", "kafka-streams");
|
super("kafka", "kafka-streams");
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
protected boolean defaultEnabled() {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public AgentBuilder apply(final AgentBuilder agentBuilder) {
|
public AgentBuilder apply(final AgentBuilder agentBuilder) {
|
||||||
return agentBuilder
|
return agentBuilder
|
||||||
|
@ -106,11 +101,6 @@ public class KafkaStreamsProcessorInstrumentation {
|
||||||
super("kafka", "kafka-streams");
|
super("kafka", "kafka-streams");
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
protected boolean defaultEnabled() {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public AgentBuilder apply(final AgentBuilder agentBuilder) {
|
public AgentBuilder apply(final AgentBuilder agentBuilder) {
|
||||||
return agentBuilder
|
return agentBuilder
|
||||||
|
|
|
@ -26,11 +26,6 @@ public class KafkaStreamsSourceNodeRecordDeserializerInstrumentation {
|
||||||
super("kafka", "kafka-streams");
|
super("kafka", "kafka-streams");
|
||||||
}
|
}
|
||||||
|
|
||||||
@Override
|
|
||||||
protected boolean defaultEnabled() {
|
|
||||||
return false;
|
|
||||||
}
|
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public AgentBuilder apply(final AgentBuilder agentBuilder) {
|
public AgentBuilder apply(final AgentBuilder agentBuilder) {
|
||||||
return agentBuilder
|
return agentBuilder
|
||||||
|
|
|
@ -1,5 +1,3 @@
|
||||||
import ch.qos.logback.classic.Level
|
|
||||||
import ch.qos.logback.classic.Logger
|
|
||||||
import datadog.trace.agent.test.AgentTestRunner
|
import datadog.trace.agent.test.AgentTestRunner
|
||||||
import org.apache.kafka.clients.consumer.ConsumerRecord
|
import org.apache.kafka.clients.consumer.ConsumerRecord
|
||||||
import org.apache.kafka.common.serialization.Serdes
|
import org.apache.kafka.common.serialization.Serdes
|
||||||
|
@ -9,7 +7,6 @@ import org.apache.kafka.streams.kstream.KStream
|
||||||
import org.apache.kafka.streams.kstream.KStreamBuilder
|
import org.apache.kafka.streams.kstream.KStreamBuilder
|
||||||
import org.apache.kafka.streams.kstream.ValueMapper
|
import org.apache.kafka.streams.kstream.ValueMapper
|
||||||
import org.junit.ClassRule
|
import org.junit.ClassRule
|
||||||
import org.slf4j.LoggerFactory
|
|
||||||
import org.springframework.kafka.core.DefaultKafkaConsumerFactory
|
import org.springframework.kafka.core.DefaultKafkaConsumerFactory
|
||||||
import org.springframework.kafka.core.DefaultKafkaProducerFactory
|
import org.springframework.kafka.core.DefaultKafkaProducerFactory
|
||||||
import org.springframework.kafka.core.KafkaTemplate
|
import org.springframework.kafka.core.KafkaTemplate
|
||||||
|
@ -30,12 +27,6 @@ class KafkaStreamsTest extends AgentTestRunner {
|
||||||
static final STREAM_PENDING = "test.pending"
|
static final STREAM_PENDING = "test.pending"
|
||||||
static final STREAM_PROCESSED = "test.processed"
|
static final STREAM_PROCESSED = "test.processed"
|
||||||
|
|
||||||
static {
|
|
||||||
((Logger) LoggerFactory.getLogger(Logger.ROOT_LOGGER_NAME)).setLevel(Level.WARN)
|
|
||||||
((Logger) LoggerFactory.getLogger("datadog")).setLevel(Level.DEBUG)
|
|
||||||
System.setProperty("dd.integration.kafka.enabled", "true")
|
|
||||||
}
|
|
||||||
|
|
||||||
@Shared
|
@Shared
|
||||||
@ClassRule
|
@ClassRule
|
||||||
KafkaEmbedded embeddedKafka = new KafkaEmbedded(1, true, STREAM_PENDING, STREAM_PROCESSED)
|
KafkaEmbedded embeddedKafka = new KafkaEmbedded(1, true, STREAM_PENDING, STREAM_PROCESSED)
|
||||||
|
|
|
@ -15,7 +15,7 @@ plugins {
|
||||||
|
|
||||||
allprojects {
|
allprojects {
|
||||||
group = 'com.datadoghq'
|
group = 'com.datadoghq'
|
||||||
version = '0.5.1-SNAPSHOT'
|
version = '0.6.0-SNAPSHOT'
|
||||||
|
|
||||||
apply from: "${rootDir}/gradle/dependencies.gradle"
|
apply from: "${rootDir}/gradle/dependencies.gradle"
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue