Updates to zipkin 0.11

The only notable change for Sleuth is an artifact id change from
spanstore to storage.
This commit is contained in:
Adrian Cole
2016-04-03 21:04:55 +08:00
parent b3c78c139d
commit eaa008f933
8 changed files with 53 additions and 42 deletions

View File

@@ -16,8 +16,8 @@
<properties>
<spring-cloud-netflix.version>1.1.0.BUILD-SNAPSHOT</spring-cloud-netflix.version>
<aspectj.version>1.8.4</aspectj.version>
<zipkin-java.version>0.10.4</zipkin-java.version>
<zipkin-ui.version>1.39.0</zipkin-ui.version>
<zipkin-java.version>0.11.0</zipkin-java.version>
<zipkin-ui.version>1.39.3</zipkin-ui.version>
</properties>
<dependencyManagement>
<dependencies>
@@ -85,7 +85,7 @@
</dependency>
<dependency>
<groupId>io.zipkin.java</groupId>
<artifactId>spanstore-jdbc</artifactId>
<artifactId>storage-jdbc</artifactId>
<version>${zipkin-java.version}</version>
</dependency>
<dependency>

View File

@@ -59,12 +59,12 @@
<dependency>
<groupId>io.zipkin.java</groupId>
<artifactId>zipkin</artifactId>
<version>0.10.4</version>
<version>0.11.0</version>
</dependency>
<dependency>
<groupId>io.zipkin.java</groupId>
<artifactId>zipkin-server</artifactId>
<version>0.10.4</version>
<version>0.11.0</version>
</dependency>
</dependencies>
</dependencyManagement>

View File

@@ -35,7 +35,7 @@
<properties>
<docker.image.prefix>springio</docker.image.prefix>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<zipkin-ui.version>1.39.0</zipkin-ui.version>
<zipkin-ui.version>1.39.3</zipkin-ui.version>
<java.version>1.8</java.version>
<sonar.skip>true</sonar.skip>
</properties>

View File

@@ -1,18 +1,22 @@
storage:
image: openzipkin/zipkin-mysql:1.39.0
container_name: mysql
ports:
- 3306:3306
query:
image: openzipkin/zipkin-java:0.10.4
environment:
- STORAGE_TYPE=mysql
- MYSQL_HOST=mysql
- MYSQL_PORT=3306
ports:
# Historical port used for the Zipkin HTTP Api
- 9411:9411
# Zipkin UI used to be on a separate process listening on port 8080
- 8080:9411
links:
- storage
version: '2'
services:
storage:
image: openzipkin/zipkin-mysql:1.39.3
container_name: mysql
ports:
- 3306:3306
query:
image: openzipkin/zipkin-java:0.11.0
environment:
- STORAGE_TYPE=mysql
- MYSQL_HOST=mysql
ports:
# Listen port for the Scribe transport
- 9410:9410
# Historical port used for the Zipkin HTTP Api
- 9411:9411
# Zipkin UI used to be on a separate process listening on port 8080
- 8080:9411
depends_on:
- storage

View File

@@ -63,7 +63,7 @@
</dependency>
<dependency>
<groupId>io.zipkin.java</groupId>
<artifactId>spanstore-jdbc</artifactId>
<artifactId>storage-jdbc</artifactId>
</dependency>
<dependency>
<groupId>com.h2database</groupId>

View File

@@ -33,12 +33,12 @@ import org.springframework.integration.annotation.MessageEndpoint;
import org.springframework.integration.annotation.ServiceActivator;
import zipkin.Annotation;
import zipkin.AsyncSpanConsumer;
import zipkin.BinaryAnnotation;
import zipkin.BinaryAnnotation.Type;
import zipkin.Endpoint;
import zipkin.Sampler;
import zipkin.Span.Builder;
import zipkin.async.AsyncSpanConsumer;
/**
* A message listener that is turned on if Sleuth Stream is disabled.

View File

@@ -1,15 +1,22 @@
mysql:
image: openzipkin/zipkin-mysql:1.38.1
ports:
- 3306:3306
query:
image: openzipkin/zipkin-java:0.9.3
environment:
- STORAGE_TYPE=mysql
ports:
# Historical port used for the Zipkin HTTP Api
- 9411:9411
# Zipkin UI used to be on a separate process listening on port 8080
- 8080:9411
links:
- mysql:storage
version: '2'
services:
storage:
image: openzipkin/zipkin-mysql:1.39.3
container_name: mysql
ports:
- 3306:3306
query:
image: openzipkin/zipkin-java:0.11.0
environment:
- STORAGE_TYPE=mysql
- MYSQL_HOST=mysql
ports:
# Listen port for the Scribe transport
- 9410:9410
# Historical port used for the Zipkin HTTP Api
- 9411:9411
# Zipkin UI used to be on a separate process listening on port 8080
- 8080:9411
depends_on:
- storage

View File

@@ -121,7 +121,7 @@ public class ZipkinSpanListener implements SpanReporter {
String serviceName = span.tags().containsKey(Span.SPAN_PEER_SERVICE_TAG_NAME) ?
span.tags().get(Span.SPAN_PEER_SERVICE_TAG_NAME) : this.endpointLocator.local().serviceName;
zipkinSpan.addBinaryAnnotation(BinaryAnnotation.address(Constants.SERVER_ADDR,
Endpoint.create(serviceName, this.endpointLocator.local().ipv4, this.endpointLocator.local().port)));
new Endpoint.Builder(this.endpointLocator.local()).serviceName(serviceName).build()));
}
private boolean notClientOrServer(Span span) {