This commit is contained in:
Marcin Grzejszczak
2016-03-21 14:33:48 +01:00
parent 35e8965e0a
commit a0048a806e
62 changed files with 7 additions and 66 deletions

View File

@@ -20,7 +20,6 @@ package org.springframework.cloud.sleuth;
* Span reporter that does nothing
*
* @author Marcin Grzejszczak
*
* @since 1.0.0
*/
public class NoOpSpanReporter implements SpanReporter {

View File

@@ -22,7 +22,6 @@ package org.springframework.cloud.sleuth;
* </a>OpenTracing</a>
*
* @author Marcin Grzejszczak
*
* @since 1.0.0
*/
public interface SpanExtractor<T> {

View File

@@ -22,7 +22,6 @@ package org.springframework.cloud.sleuth;
* </a>OpenTracing</a>
*
* @author Marcin Grzejszczak
*
* @since 1.0.0
*/
public interface SpanInjector<T> {

View File

@@ -20,7 +20,6 @@ package org.springframework.cloud.sleuth;
* Contract for reporting Sleuth spans for collection. For example to Zipkin.
*
* @author Marcin Grzejszczak
*
* @since 1.0.0
*/
public interface SpanReporter {

View File

@@ -28,6 +28,7 @@ import org.springframework.cloud.sleuth.Tracer;
* the span is not closed - it gets {@link Tracer#detach(Span) detached}.
*
* @author Marcin Grzejszczak
* @since 1.0.0
*/
public class TraceContinuingCallable<V> extends TraceCallable<V> implements Callable<V> {

View File

@@ -31,6 +31,7 @@ import com.netflix.hystrix.HystrixCommand;
* @author Tomasz Nurkiewicz, 4financeIT
* @author Marcin Grzejszczak, 4financeIT
* @author Spencer Gibb
* @since 1.0.0
*/
public abstract class TraceCommand<R> extends HystrixCommand<R> {

View File

@@ -27,7 +27,6 @@ import org.springframework.messaging.Message;
* Creates a {@link SpanBuilder} from {@link Message}
*
* @author Marcin Grzejszczak
*
* @since 1.0.0
*/
public class MessagingSpanExtractor implements SpanExtractor<Message<?>> {

View File

@@ -33,8 +33,6 @@ import org.springframework.util.StringUtils;
* Creates a {@link Span.SpanBuilder} from {@link Message}
*
* @author Marcin Grzejszczak
*
* @since 1.0.0
*/
class MessagingSpanInjector implements SpanInjector<MessageBuilder<?>> {

View File

@@ -32,7 +32,6 @@ import org.springframework.messaging.support.MessageBuilder;
* by Messaging and WebSockets
*
* @author Marcin Grzejszczak
*
* @since 1.0.0
*/
@Configuration

View File

@@ -36,9 +36,9 @@ import org.springframework.context.annotation.EnableAspectJAutoProxy;
*
* @author Michal Chmielarz, 4financeIT
* @author Spencer Gibb
* @since 1.0.0
*
* @see TraceSchedulingAspect
* @since 1.0.0
*/
@Configuration
@EnableAspectJAutoProxy

View File

@@ -56,12 +56,11 @@ import static org.springframework.util.StringUtils.hasText;
* @author Marcin Grzejszczak
* @author Spencer Gibb
* @author Dave Syer
* @since 1.0.0
*
* @see Tracer
* @see TraceKeys
* @see TraceWebAutoConfiguration#traceFilter
*
* @since 1.0.0
*/
@Order(Ordered.HIGHEST_PRECEDENCE + 5)
public class TraceFilter extends OncePerRequestFilter {

View File

@@ -54,7 +54,6 @@ import org.springframework.web.context.request.async.WebAsyncTask;
* @author Michal Chmielarz, 4financeIT
* @author Marcin Grzejszczak
* @author Spencer Gibb
*
* @since 1.0.0
*
* @see org.springframework.web.bind.annotation.RestController

View File

@@ -50,7 +50,6 @@ import org.springframework.util.StringUtils;
* @author Michal Chmielarz, 4financeIT
* @author Marcin Grzejszczak
* @author Spencer Gibb
*
* @since 1.0.0
*/
@Configuration

View File

@@ -37,7 +37,6 @@ import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
*
* @author Marcin Grzejszczak
* @author Spencer Gibb
*
* @since 1.0.0
*/
public class TraceAsyncClientHttpRequestFactoryWrapper extends AbstractTraceHttpRequestInterceptor

View File

@@ -29,7 +29,6 @@ import org.springframework.http.client.ClientHttpResponse;
* {@link TraceRestTemplateInterceptor#finish() closes the span}
*
* @author Dave Syer
*
* @since 1.0.0
*/
public class TraceHttpResponse implements ClientHttpResponse {

View File

@@ -31,10 +31,9 @@ import org.springframework.http.client.ClientHttpResponse;
*
* @author Marcin Grzejszczak
* @author Spencer Gibb
* @since 1.0.0
*
* @see org.springframework.web.client.RestTemplate
*
* @since 1.0.0
*/
public class TraceRestTemplateInterceptor extends AbstractTraceHttpRequestInterceptor
implements ClientHttpRequestInterceptor {

View File

@@ -37,7 +37,6 @@ import org.springframework.web.client.AsyncRestTemplate;
* {@link AsyncRestTemplate}
*
* @author Marcin Grzejszczak
*
* @since 1.0.0
*/
@Configuration

View File

@@ -42,7 +42,6 @@ import org.springframework.web.client.RestTemplate;
* enables span information propagation when using {@link RestTemplate}
*
* @author Marcin Grzejszczak
*
* @since 1.0.0
*/
@Configuration

View File

@@ -54,7 +54,6 @@ import feign.codec.Decoder;
* Auto-configuration} enables span information propagation when using Feign.
*
* @author Marcin Grzejszczak
*
* @since 1.0.0
*/
@Configuration

View File

@@ -25,7 +25,6 @@ import com.netflix.zuul.ZuulFilter;
* A post request {@link ZuulFilter} that publishes an event upon start of the filtering
*
* @author Dave Syer
*
* @since 1.0.0
*/
public class TracePostZuulFilter extends ZuulFilter {

View File

@@ -28,7 +28,6 @@ import com.netflix.zuul.context.RequestContext;
* from the current span. We're doing so to ensure tracing propagates to the next hop.
*
* @author Dave Syer
*
* @since 1.0.0
*/
public class TracePreZuulFilter extends ZuulFilter {

View File

@@ -37,7 +37,6 @@ import com.netflix.niws.client.http.RestClient;
* Propagates traces downstream via http headers that contain trace metadata.
*
* @author Spencer Gibb
*
* @since 1.0.0
*/
public class TraceRestClientRibbonCommandFactory extends RestClientRibbonCommandFactory {

View File

@@ -39,7 +39,6 @@ import com.netflix.zuul.context.RequestContext;
* enables span information propagation when using Zuul.
*
* @author Dave Syer
*
* @since 1.0.0
*/
@Configuration

View File

@@ -22,7 +22,6 @@ import org.springframework.cloud.sleuth.Span;
* Logger of Spans that does nothing
*
* @author Marcin Grzejszczak
*
* @since 1.0.0
*/
public class NoOpSpanLogger implements SpanLogger {

View File

@@ -32,7 +32,6 @@ import org.springframework.context.annotation.Configuration;
* Note: this is only available for Slf4j
*
* @author Spencer Gibb
*
* @since 1.0.0
*/
@Configuration

View File

@@ -27,7 +27,6 @@ import org.springframework.cloud.sleuth.Span;
* started / stopped / continued.
*
* @author Spencer Gibb
*
* @since 1.0.0
*/
public class Slf4jSpanLogger implements SpanLogger {

View File

@@ -22,7 +22,6 @@ import org.springframework.cloud.sleuth.Span;
* Contract for implementations responsible for logging Spans
*
* @author Marcin Grzejszczak
*
* @since 1.0.0
*/
public interface SpanLogger {

View File

@@ -7,7 +7,6 @@ import org.springframework.boot.actuate.metrics.CounterService;
* Operates on a {@link CounterService} underneath
*
* @author Marcin Grzejszczak
*
* @since 1.0.0
*/
public class CounterServiceBasedSpanMetricReporter implements SpanMetricReporter {

View File

@@ -4,7 +4,6 @@ package org.springframework.cloud.sleuth.metric;
* {@link SpanMetricReporter} that does nothing
*
* @author Marcin Grzejszczak
*
* @since 1.0.0
*/
public class NoOpSpanMetricReporter implements SpanMetricReporter {

View File

@@ -6,7 +6,6 @@ import org.springframework.boot.context.properties.ConfigurationProperties;
* Configuration properties for Sleuth related metrics
*
* @author Marcin Grzejszczak
*
* @since 1.0.0
*/
@ConfigurationProperties("spring.sleuth.metric")

View File

@@ -4,7 +4,6 @@ package org.springframework.cloud.sleuth.metric;
* Contract for a service that measures the number of accepted / dropped spans.
*
* @author Marcin Grzejszczak
*
* @since 1.0.0
*/
public interface SpanMetricReporter {

View File

@@ -31,7 +31,6 @@ import org.springframework.context.annotation.Configuration;
* enables Sleuth related metrics reporting
*
* @author Marcin Grzejszczak
*
* @since 1.0.0
*/
@Configuration

View File

@@ -23,7 +23,6 @@ import org.springframework.cloud.sleuth.Span;
* {@link Sampler} that traces each action
*
* @author Spencer Gibb
*
* @since 1.0.0
*/
public class AlwaysSampler implements Sampler {

View File

@@ -24,7 +24,6 @@ import org.springframework.cloud.sleuth.SpanAccessor;
* {@link Sampler} that traces only if there is already some tracing going on.
*
* @author Spencer Gibb
*
* @since 1.0.0
*
* @see SpanAccessor#isTracing()

View File

@@ -23,7 +23,6 @@ import org.springframework.cloud.sleuth.Span;
* {@link Sampler} that never traces
*
* @author Spencer Gibb
*
* @since 1.0.0
*/
public class NeverSampler implements Sampler {

View File

@@ -21,7 +21,6 @@ import org.springframework.cloud.sleuth.Span;
*
* @author Marcin Grzejszczak
* @author Adrian Cole
*
* @since 1.0.0
*/
public class PercentageBasedSampler implements Sampler {

View File

@@ -7,7 +7,6 @@ import org.springframework.boot.context.properties.ConfigurationProperties;
*
* @author Marcin Grzejszczak
* @author Adrian Cole
*
* @since 1.0.0
*/
@ConfigurationProperties("spring.sleuth.sampler")

View File

@@ -33,7 +33,6 @@ import org.springframework.cloud.sleuth.util.ExceptionUtils;
* Default implementation of {@link Tracer}
*
* @author Spencer Gibb
*
* @since 1.0.0
*/
public class DefaultTracer implements Tracer {

View File

@@ -25,8 +25,6 @@ import org.springframework.core.NamedThreadLocal;
*
* @author Spencer Gibb
* @author Dave Syer
*
* @since 1.0.0
*/
class SpanContextHolder {

View File

@@ -26,7 +26,6 @@ import org.apache.commons.logging.Log;
* when there are some issues with tracing.
*
* @author Spencer Gibb
*
* @since 1.0.0
*/
public final class ExceptionUtils {

View File

@@ -28,7 +28,6 @@ import org.springframework.util.Assert;
* {@link DiscoveryClient}.
*
* @author Dave Syer
*
* @since 1.0.0
*/
public class DiscoveryClientHostLocator implements HostLocator {

View File

@@ -27,7 +27,6 @@ import com.fasterxml.jackson.annotation.JsonInclude;
* Represents the host from which the span was sent
*
* @author Dave Syer
*
* @since 1.0.0
*/
@JsonInclude(JsonInclude.Include.NON_NULL)

View File

@@ -23,7 +23,6 @@ import org.springframework.cloud.sleuth.Span;
* environment properties might be available).
*
* @author Dave Syer
*
* @since 1.0.0
*/
public interface HostLocator {

View File

@@ -32,7 +32,6 @@ import org.springframework.util.Assert;
* </ul>
*
* @author Dave Syer
*
* @since 1.0.0
*/
public class ServerPropertiesHostLocator implements HostLocator {

View File

@@ -24,11 +24,10 @@ import org.springframework.messaging.SubscribableChannel;
* instrumented applications. Span data comes into the channel in the form of
* {@link Spans}, buffering multiple actual spans into a single payload.
*
* @see SleuthSource
*
* @author Dave Syer
*
* @since 1.0.0
*
* @see SleuthSource
*/
public interface SleuthSink {

View File

@@ -26,7 +26,6 @@ import org.springframework.messaging.MessageChannel;
* spans, and if it does it should attempt to account for and report the number dropped.
*
* @author Dave Syer
*
* @since 1.0.0
*
* @see SleuthSink

View File

@@ -48,7 +48,6 @@ import org.springframework.messaging.support.ChannelInterceptor;
* is no additional configuration to do by default).
*
* @author Dave Syer
*
* @since 1.0.0
*/
@Configuration

View File

@@ -22,7 +22,6 @@ import org.springframework.boot.context.properties.ConfigurationProperties;
* Properties related to Sleuth Stream
*
* @author Dave Syer
*
* @since 1.0.0
*/
@ConfigurationProperties("spring.sleuth.stream")

View File

@@ -27,7 +27,6 @@ import com.fasterxml.jackson.annotation.JsonInclude;
* Data transfer object for a collection of spans from a given host.
*
* @author Dave Syer
*
* @since 1.0.0
*/
@JsonInclude(JsonInclude.Include.NON_DEFAULT)

View File

@@ -41,7 +41,6 @@ import org.springframework.core.io.support.PropertiesLoaderUtils;
* Sleuth Stream.
*
* @author Dave Syer
*
* @since 1.0.0
*/
public class StreamEnvironmentPostProcessor implements EnvironmentPostProcessor {

View File

@@ -33,7 +33,6 @@ import org.springframework.integration.annotation.MessageEndpoint;
* A message source for spans. Also handles RPC flavoured annotations.
*
* @author Dave Syer
*
* @since 1.0.0
*/
@MessageEndpoint

View File

@@ -30,7 +30,6 @@ import zipkin.server.EnableZipkinServer;
* Spring Cloud Stream, for example RabbitMQ.
*
* @author Dave Syer
*
* @since 1.0.0
*
* @see ZipkinMessageListener

View File

@@ -33,7 +33,6 @@ import org.springframework.core.env.PropertySource;
* Stream.
*
* @author Dave Syer
*
* @since 1.0.0
*/
public class StreamEnvironmentPostProcessor implements EnvironmentPostProcessor {

View File

@@ -47,7 +47,6 @@ import zipkin.SpanStore;
* Asynchronously stores the received spans in a {@link SpanStore}.
*
* @author Dave Syer
*
* @since 1.0.0
*
* @see NotSleuthStreamClient

View File

@@ -27,7 +27,6 @@ import zipkin.Endpoint;
* {@link DiscoveryClient}.
*
* @author Dave Syer
*
* @since 1.0.0
*/
public class DiscoveryClientEndpointLocator implements EndpointLocator {

View File

@@ -22,7 +22,6 @@ import zipkin.Endpoint;
* Strategy for locating a zipkin {@linkplain Endpoint} for the current process.
*
* @author Dave Syer
*
* @since 1.0.0
*/
public interface EndpointLocator {

View File

@@ -28,7 +28,6 @@ import static java.util.concurrent.TimeUnit.SECONDS;
* Submits spans using Zipkin's {@code POST /spans} endpoint.
*
* @author Adrian Cole
*
* @since 1.0.0
*/
public final class HttpZipkinSpanReporter

View File

@@ -32,7 +32,6 @@ import zipkin.Endpoint;
* </ul>
*
* @author Dave Syer
*
* @since 1.0.0
*/
public class ServerPropertiesEndpointLocator implements EndpointLocator {

View File

@@ -42,7 +42,6 @@ import org.springframework.context.annotation.Configuration;
* {@link PercentageBasedSampler}.
*
* @author Spencer Gibb
*
* @since 1.0.0
*/
@Configuration

View File

@@ -22,7 +22,6 @@ import org.springframework.boot.context.properties.ConfigurationProperties;
* Zipkin settings
*
* @author Spencer Gibb
*
* @since 1.0.0
*/
@ConfigurationProperties("spring.zipkin")

View File

@@ -35,7 +35,6 @@ import zipkin.Endpoint;
* Listener of Sleuth events. Reports to Zipkin via {@link ZipkinSpanReporter}.
*
* @author Spencer Gibb
*
* @since 1.0.0
*/
public class ZipkinSpanListener implements SpanReporter {

View File

@@ -4,7 +4,6 @@ package org.springframework.cloud.sleuth.zipkin;
* Contract for reporting Zipkin spans to Zipkin.
*
* @author Adrian Cole
*
* @since 1.0.0
*/
public interface ZipkinSpanReporter {