SpringCloud/spring-cloud-sleuth
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Updates to zipkin 0.10.4

Browse Source 
This updates to the latest release. Beyond bug fixes, there are some
notable changes:

* storage: writes are now via AsyncSpanConsumer
* storage: added elasticsearch
* zipkin-ui: constrains start time to look for traces
* zipkin-ui: assets set cache headers, increasing responsiveness
* core: debug logging available for zipkin.internal.DependencyLinker
This commit is contained in:
Adrian Cole
2016-03-31 19:31:45 +08:00
parent 9aba475ac9
commit 8382a823e5
8 changed files with 21 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
spring-cloud-sleuth-zipkin-stream/src/main/java/org/springframework/cloud/sleuth/zipkin/stream/ZipkinMessageListener.java
View File

@@ -37,14 +37,12 @@ import zipkin.BinaryAnnotation;
import zipkin.BinaryAnnotation.Type;
import zipkin.Endpoint;
import zipkin.Sampler;
import zipkin.SamplingSpanStoreConsumer;
import zipkin.Span.Builder;
import zipkin.SpanConsumer;
import zipkin.SpanStore;
import zipkin.async.AsyncSpanConsumer;
/**
* A message listener that is turned on if Sleuth Stream is disabled.
* Asynchronously stores the received spans in a {@link SpanStore}.
* Asynchronously stores the received spans using {@link AsyncSpanConsumer}.
*
* @author Dave Syer
* @since 1.0.0
@@ -58,17 +56,17 @@ public class ZipkinMessageListener {
private static final org.apache.commons.logging.Log log = org.apache.commons.logging.LogFactory
.getLog(ZipkinMessageListener.class);
static final String UNKNOWN_PROCESS_ID = "unknown";
final SpanConsumer consumer;
final AsyncSpanConsumer consumer;
@Autowired
ZipkinMessageListener(SpanStore spanStore, Sampler sampler) {
this.consumer = SamplingSpanStoreConsumer.create(sampler, spanStore);
ZipkinMessageListener(AsyncSpanConsumer consumer) {
this.consumer = consumer;
}
@ServiceActivator(inputChannel = SleuthSink.INPUT)
public void sink(Spans input) {
List<zipkin.Span> converted = ConvertToZipkinSpanList.convert(input);
this.consumer.accept(converted);
this.consumer.accept(converted, AsyncSpanConsumer.NOOP_CALLBACK);
}
/**