Moved ReporterMetrics sleuthReporterMetrics() to TraceAutoConfiguration so other implementations can use the same default
This commit is contained in:
@@ -31,7 +31,9 @@ import brave.propagation.Propagation;
|
||||
import brave.propagation.ThreadLocalCurrentTraceContext;
|
||||
import brave.sampler.Sampler;
|
||||
import zipkin2.Span;
|
||||
import zipkin2.reporter.InMemoryReporterMetrics;
|
||||
import zipkin2.reporter.Reporter;
|
||||
import zipkin2.reporter.ReporterMetrics;
|
||||
|
||||
import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.beans.factory.annotation.Value;
|
||||
@@ -171,6 +173,12 @@ public class TraceAutoConfiguration {
|
||||
return ThreadLocalCurrentTraceContext.newBuilder();
|
||||
}
|
||||
|
||||
@Bean
|
||||
@ConditionalOnMissingBean
|
||||
ReporterMetrics sleuthReporterMetrics() {
|
||||
return new InMemoryReporterMetrics();
|
||||
}
|
||||
|
||||
@Bean
|
||||
@ConditionalOnMissingBean
|
||||
Reporter<zipkin2.Span> noOpSpanReporter() {
|
||||
|
||||
@@ -64,7 +64,8 @@ import org.springframework.web.client.RestTemplate;
|
||||
*/
|
||||
@Configuration
|
||||
@EnableConfigurationProperties(ZipkinProperties.class)
|
||||
@ConditionalOnProperty(value = "spring.zipkin.enabled", matchIfMissing = true)
|
||||
@ConditionalOnProperty(value = { "spring.sleuth.enabled",
|
||||
"spring.zipkin.enabled" }, matchIfMissing = true)
|
||||
@AutoConfigureBefore(TraceAutoConfiguration.class)
|
||||
@AutoConfigureAfter(name = "org.springframework.cloud.autoconfigure.RefreshAutoConfiguration")
|
||||
@Import({ ZipkinSenderConfigurationImportSelector.class, SamplerAutoConfiguration.class })
|
||||
@@ -112,12 +113,6 @@ public class ZipkinAutoConfiguration {
|
||||
return new DefaultZipkinRestTemplateCustomizer(zipkinProperties);
|
||||
}
|
||||
|
||||
@Bean
|
||||
@ConditionalOnMissingBean
|
||||
ReporterMetrics sleuthReporterMetrics() {
|
||||
return new InMemoryReporterMetrics();
|
||||
}
|
||||
|
||||
@Configuration
|
||||
@ConditionalOnMissingBean(EndpointLocator.class)
|
||||
@ConditionalOnProperty(value = "spring.zipkin.locator.discovery.enabled", havingValue = "false", matchIfMissing = true)
|
||||
|
||||
@@ -125,7 +125,8 @@ public class ZipkinAutoConfigurationTests {
|
||||
this.context = new AnnotationConfigApplicationContext();
|
||||
environment().setProperty("spring.zipkin.rabbitmq.queue", "zipkin2");
|
||||
this.context.register(PropertyPlaceholderAutoConfiguration.class,
|
||||
RabbitAutoConfiguration.class, ZipkinAutoConfiguration.class);
|
||||
RabbitAutoConfiguration.class, ZipkinAutoConfiguration.class,
|
||||
TraceAutoConfiguration.class);
|
||||
this.context.refresh();
|
||||
|
||||
then(this.context.getBean(Sender.class)).isInstanceOf(RabbitMQSender.class);
|
||||
@@ -139,7 +140,8 @@ public class ZipkinAutoConfigurationTests {
|
||||
environment().setProperty("spring.zipkin.kafka.topic", "zipkin2");
|
||||
environment().setProperty("spring.zipkin.sender.type", "kafka");
|
||||
this.context.register(PropertyPlaceholderAutoConfiguration.class,
|
||||
KafkaAutoConfiguration.class, ZipkinAutoConfiguration.class);
|
||||
KafkaAutoConfiguration.class, ZipkinAutoConfiguration.class,
|
||||
TraceAutoConfiguration.class);
|
||||
this.context.refresh();
|
||||
|
||||
then(this.context.getBean(Sender.class)).isInstanceOf(KafkaSender.class);
|
||||
@@ -153,7 +155,7 @@ public class ZipkinAutoConfigurationTests {
|
||||
environment().setProperty("spring.zipkin.sender.type", "web");
|
||||
this.context.register(PropertyPlaceholderAutoConfiguration.class,
|
||||
RabbitAutoConfiguration.class, KafkaAutoConfiguration.class,
|
||||
ZipkinAutoConfiguration.class);
|
||||
ZipkinAutoConfiguration.class, TraceAutoConfiguration.class);
|
||||
this.context.refresh();
|
||||
|
||||
then(this.context.getBean(Sender.class).getClass().getName())
|
||||
@@ -168,7 +170,7 @@ public class ZipkinAutoConfigurationTests {
|
||||
environment().setProperty("spring.zipkin.sender.type", "WEB");
|
||||
this.context.register(PropertyPlaceholderAutoConfiguration.class,
|
||||
RabbitAutoConfiguration.class, KafkaAutoConfiguration.class,
|
||||
ZipkinAutoConfiguration.class);
|
||||
ZipkinAutoConfiguration.class, TraceAutoConfiguration.class);
|
||||
this.context.refresh();
|
||||
|
||||
then(this.context.getBean(Sender.class).getClass().getName())
|
||||
@@ -182,7 +184,7 @@ public class ZipkinAutoConfigurationTests {
|
||||
this.context = new AnnotationConfigApplicationContext();
|
||||
this.context.register(PropertyPlaceholderAutoConfiguration.class,
|
||||
RabbitAutoConfiguration.class, KafkaAutoConfiguration.class,
|
||||
ZipkinAutoConfiguration.class);
|
||||
ZipkinAutoConfiguration.class, TraceAutoConfiguration.class);
|
||||
this.context.refresh();
|
||||
|
||||
then(this.context.getBean(Sender.class)).isInstanceOf(RabbitMQSender.class);
|
||||
|
||||
Reference in New Issue
Block a user