From 3e21eaa681d7b29ac825f53f0e8594f0307a69c6 Mon Sep 17 00:00:00 2001 From: wusheng Date: Sat, 26 Nov 2016 17:15:07 +0800 Subject: [PATCH] 1. add skywalking-opentracing-kit module 2.add a network client --- pom.xml | 2 ++ .../com/a/eye/skywalking/network/Client.java | 11 ++++++++--- .../network/grpc/client/TraceSearchClient.java | 16 ++++++++++++++++ skywalking-opentracing-kit/pom.xml | 11 +++++++++++ 4 files changed, 37 insertions(+), 3 deletions(-) create mode 100644 skywalking-network/src/main/java/com/a/eye/skywalking/network/grpc/client/TraceSearchClient.java create mode 100644 skywalking-opentracing-kit/pom.xml diff --git a/pom.xml b/pom.xml index 2bbdc2df2..a54378bec 100644 --- a/pom.xml +++ b/pom.xml @@ -13,6 +13,8 @@ skywalking-storage-center + skywalking-opentracing-kit + samples/skywalking-auth samples/skywalking-example diff --git a/skywalking-network/src/main/java/com/a/eye/skywalking/network/Client.java b/skywalking-network/src/main/java/com/a/eye/skywalking/network/Client.java index 5c9681e2c..29e1d696d 100644 --- a/skywalking-network/src/main/java/com/a/eye/skywalking/network/Client.java +++ b/skywalking-network/src/main/java/com/a/eye/skywalking/network/Client.java @@ -1,19 +1,21 @@ package com.a.eye.skywalking.network; import com.a.eye.skywalking.network.grpc.SpanStorageServiceGrpc; +import com.a.eye.skywalking.network.grpc.TraceSearchServiceGrpc; import com.a.eye.skywalking.network.grpc.client.SpanStorageClient; +import com.a.eye.skywalking.network.grpc.client.TraceSearchClient; import io.grpc.ManagedChannel; import io.grpc.ManagedChannelBuilder; -import static com.a.eye.skywalking.network.grpc.SpanStorageServiceGrpc.newStub; - public class Client { private ManagedChannel channel; private SpanStorageServiceGrpc.SpanStorageServiceStub spanStorageStub; + private TraceSearchServiceGrpc.TraceSearchServiceStub traceSearchServiceStub; public Client(String ip, int address) { channel = ManagedChannelBuilder.forAddress(ip, address).usePlaintext(true).build(); - spanStorageStub = newStub(channel); + spanStorageStub = SpanStorageServiceGrpc.newStub(channel); + traceSearchServiceStub = TraceSearchServiceGrpc.newStub(channel); } @@ -22,4 +24,7 @@ public class Client { } + public TraceSearchClient newTraceSearchClient(){ + return new TraceSearchClient(traceSearchServiceStub); + } } diff --git a/skywalking-network/src/main/java/com/a/eye/skywalking/network/grpc/client/TraceSearchClient.java b/skywalking-network/src/main/java/com/a/eye/skywalking/network/grpc/client/TraceSearchClient.java new file mode 100644 index 000000000..ec4df2f05 --- /dev/null +++ b/skywalking-network/src/main/java/com/a/eye/skywalking/network/grpc/client/TraceSearchClient.java @@ -0,0 +1,16 @@ +package com.a.eye.skywalking.network.grpc.client; + +import com.a.eye.skywalking.network.grpc.TraceSearchServiceGrpc; + +/** + * Created by wusheng on 2016/11/26. + */ +public class TraceSearchClient { + + private final TraceSearchServiceGrpc.TraceSearchServiceStub traceSearchServiceStub; + + public TraceSearchClient(TraceSearchServiceGrpc.TraceSearchServiceStub traceSearchServiceStub) { + this.traceSearchServiceStub = traceSearchServiceStub; + } + +} diff --git a/skywalking-opentracing-kit/pom.xml b/skywalking-opentracing-kit/pom.xml new file mode 100644 index 000000000..151ca96aa --- /dev/null +++ b/skywalking-opentracing-kit/pom.xml @@ -0,0 +1,11 @@ + + + skywalking + com.a.eye + 2.0-2016 + + 4.0.0 + skywalking-opentracing-kit + jar +