aboutsummaryrefslogtreecommitdiff
path: root/testing-proto
diff options
context:
space:
mode:
authorCarl Mastrangelo <notcarl@google.com>2017-09-29 18:20:37 -0700
committerGitHub <noreply@github.com>2017-09-29 18:20:37 -0700
commit02466744bbe238403bfe16ae5ba337436ac71b7f (patch)
tree3898c6ba2851aad3fa3cc8001fff03cd8ee6b2c7 /testing-proto
parentcbcab9b4983dd490fb56168a43ec97d929657098 (diff)
downloadgrpc-grpc-java-02466744bbe238403bfe16ae5ba337436ac71b7f.tar.gz
core: move census registration into internal
also preserve tracing bit when rebuilding a MethodDescriptor
Diffstat (limited to 'testing-proto')
-rw-r--r--testing-proto/src/test/java/io/grpc/testing/protobuf/SimpleServiceTest.java16
1 files changed, 12 insertions, 4 deletions
diff --git a/testing-proto/src/test/java/io/grpc/testing/protobuf/SimpleServiceTest.java b/testing-proto/src/test/java/io/grpc/testing/protobuf/SimpleServiceTest.java
index 300c166a1..2071f6871 100644
--- a/testing-proto/src/test/java/io/grpc/testing/protobuf/SimpleServiceTest.java
+++ b/testing-proto/src/test/java/io/grpc/testing/protobuf/SimpleServiceTest.java
@@ -24,7 +24,6 @@ import static io.grpc.MethodDescriptor.MethodType.UNARY;
import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
-import io.grpc.InternalMethodDescriptor;
import io.grpc.MethodDescriptor;
import io.opencensus.trace.Tracing;
import io.opencensus.trace.export.SampledSpanStore;
@@ -61,8 +60,9 @@ public class SimpleServiceTest {
@Test
public void registerSampledMethodsForTracing() throws Exception {
- // Make sure SimpleServiceGrpc class is loaded
+ // Make sure SimpleServiceGrpc and CensusTracingModule classes are loaded.
assertNotNull(Class.forName(SimpleServiceGrpc.class.getName()));
+ assertNotNull(Class.forName("io.grpc.internal.CensusTracingModule"));
String[] methodNames = new String[] {
"grpc.testing.SimpleService/UnaryRpc",
@@ -72,12 +72,20 @@ public class SimpleServiceTest {
ArrayList<String> expectedSpans = new ArrayList<String>();
for (String methodName : methodNames) {
- expectedSpans.add(InternalMethodDescriptor.generateTraceSpanName(false, methodName));
- expectedSpans.add(InternalMethodDescriptor.generateTraceSpanName(true, methodName));
+ expectedSpans.add(generateTraceSpanName(false, methodName));
+ expectedSpans.add(generateTraceSpanName(true, methodName));
}
SampledSpanStore sampledStore = Tracing.getExportComponent().getSampledSpanStore();
Set<String> registeredSpans = sampledStore.getRegisteredSpanNamesForCollection();
assertThat(registeredSpans).containsAllIn(expectedSpans);
}
+
+ /**
+ * Copy of {@link io.grpc.internal.CensusTracingModule#generateTraceSpanName} to break dependency.
+ */
+ private static String generateTraceSpanName(boolean isServer, String fullMethodName) {
+ String prefix = isServer ? "Recv" : "Sent";
+ return prefix + "." + fullMethodName.replace('/', '.');
+ }
}