Moved the additional spring configuration metadata around
This commit is contained in:
@@ -46,6 +46,102 @@
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable a composite text map propagator that can combine multiple propagation types into a single text map propagator.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.integration.websockets.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing for WebSockets.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.async.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable instrumenting async related components so that the tracing information is passed between threads.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.async.configurer.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable default AsyncConfigurer.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.feign.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable span information propagation when using Feign.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.feign.processor.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable post processor that wraps Feign Context in its tracing representations.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.grpc.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable span information propagation when using GRPC.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.messaging.jms.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing of JMS.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.messaging.rabbit.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing of RabbitMQ.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.messaging.kafka.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing of Kafka.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.messaging.kafka.mapper.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable DefaultKafkaHeaderMapper tracing for Kafka.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.quartz.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing for Quartz.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.mongodb.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing for MongoDb.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.rpc.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing of RPC.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.sampler.refresh.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable refresh scope for sampler.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.web.webclient.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing instrumentation for WebClient.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.integration.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable Spring Integration sleuth instrumentation.",
|
||||
"defaultValue": true
|
||||
}
|
||||
]
|
||||
}
|
||||
|
||||
@@ -1,100 +0,0 @@
|
||||
{
|
||||
"properties": [
|
||||
{
|
||||
"name": "spring.sleuth.integration.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable Spring Integration sleuth instrumentation.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.integration.websockets.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing for WebSockets.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.async.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable instrumenting async related components so that the tracing information is passed between threads.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.async.configurer.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable default AsyncConfigurer.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.feign.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable span information propagation when using Feign.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.feign.processor.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable post processor that wraps Feign Context in its tracing representations.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.grpc.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable span information propagation when using GRPC.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.messaging.jms.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing of JMS.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.messaging.rabbit.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing of RabbitMQ.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.messaging.kafka.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing of Kafka.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.messaging.kafka.mapper.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable DefaultKafkaHeaderMapper tracing for Kafka.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.quartz.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing for Quartz.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.mongodb.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing for MongoDb.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.rpc.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing of RPC.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.sampler.refresh.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable refresh scope for sampler.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.web.webclient.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing instrumentation for WebClient.",
|
||||
"defaultValue": true
|
||||
}
|
||||
]
|
||||
}
|
||||
@@ -1,100 +0,0 @@
|
||||
{
|
||||
"properties": [
|
||||
{
|
||||
"name": "spring.sleuth.integration.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable Spring Integration sleuth instrumentation.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.integration.websockets.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing for WebSockets.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.async.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable instrumenting async related components so that the tracing information is passed between threads.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.async.configurer.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable default AsyncConfigurer.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.feign.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable span information propagation when using Feign.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.feign.processor.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable post processor that wraps Feign Context in its tracing representations.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.grpc.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable span information propagation when using GRPC.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.messaging.jms.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing of JMS.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.messaging.rabbit.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing of RabbitMQ.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.messaging.kafka.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing of Kafka.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.messaging.kafka.mapper.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable DefaultKafkaHeaderMapper tracing for Kafka.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.quartz.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing for Quartz.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.mongodb.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing for MongoDb.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.rpc.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing of RPC.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.sampler.refresh.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable refresh scope for sampler.",
|
||||
"defaultValue": true
|
||||
},
|
||||
{
|
||||
"name": "spring.sleuth.web.webclient.enabled",
|
||||
"type": "java.lang.Boolean",
|
||||
"description": "Enable tracing instrumentation for WebClient.",
|
||||
"defaultValue": true
|
||||
}
|
||||
]
|
||||
}
|
||||
@@ -16,19 +16,6 @@
|
||||
|
||||
package org.springframework.cloud.sleuth.instrument.async;
|
||||
|
||||
import org.assertj.core.api.BDDAssertions;
|
||||
import org.junit.jupiter.api.BeforeEach;
|
||||
import org.junit.jupiter.api.Test;
|
||||
import org.junit.jupiter.api.extension.ExtendWith;
|
||||
import org.mockito.ArgumentCaptor;
|
||||
import org.mockito.Captor;
|
||||
import org.mockito.Mock;
|
||||
import org.mockito.junit.jupiter.MockitoExtension;
|
||||
import org.springframework.beans.factory.BeanFactory;
|
||||
import org.springframework.cloud.sleuth.SpanNamer;
|
||||
import org.springframework.cloud.sleuth.api.Span;
|
||||
import org.springframework.cloud.sleuth.api.Tracer;
|
||||
|
||||
import java.util.Arrays;
|
||||
import java.util.Collection;
|
||||
import java.util.List;
|
||||
@@ -44,6 +31,20 @@ import java.util.concurrent.ThreadFactory;
|
||||
import java.util.concurrent.TimeUnit;
|
||||
import java.util.concurrent.atomic.AtomicBoolean;
|
||||
|
||||
import org.assertj.core.api.BDDAssertions;
|
||||
import org.junit.jupiter.api.BeforeEach;
|
||||
import org.junit.jupiter.api.Test;
|
||||
import org.junit.jupiter.api.extension.ExtendWith;
|
||||
import org.mockito.ArgumentCaptor;
|
||||
import org.mockito.Captor;
|
||||
import org.mockito.Mock;
|
||||
import org.mockito.junit.jupiter.MockitoExtension;
|
||||
|
||||
import org.springframework.beans.factory.BeanFactory;
|
||||
import org.springframework.cloud.sleuth.Span;
|
||||
import org.springframework.cloud.sleuth.SpanNamer;
|
||||
import org.springframework.cloud.sleuth.Tracer;
|
||||
|
||||
import static org.assertj.core.api.Assertions.assertThat;
|
||||
import static org.assertj.core.api.Assertions.tuple;
|
||||
import static org.mockito.ArgumentMatchers.any;
|
||||
@@ -674,10 +675,9 @@ public class LazyTraceScheduledThreadPoolExecutorTests {
|
||||
final Collection<? extends Callable<String>> actual = executor
|
||||
.wrapCallableCollection(Arrays.asList(expected1, expected2, expected3));
|
||||
|
||||
assertThat(actual)
|
||||
.extracting("tracer", "delegate", "parent", "spanName")
|
||||
.containsExactly(tuple(tracer, expected1, parent, BEAN_NAME), tuple(tracer, expected2, parent, BEAN_NAME),
|
||||
tuple(tracer, expected3, parent, BEAN_NAME));
|
||||
assertThat(actual).extracting("tracer", "delegate", "parent", "spanName").containsExactly(
|
||||
tuple(tracer, expected1, parent, BEAN_NAME), tuple(tracer, expected2, parent, BEAN_NAME),
|
||||
tuple(tracer, expected3, parent, BEAN_NAME));
|
||||
}
|
||||
|
||||
@Test
|
||||
|
||||
Reference in New Issue
Block a user