Update grpc sample (#2058)

* update grpc sample

Author: aabmass

examples/build.gradle

@@ -33,8 +33,8 @@ repositories {
 group = "io.opencensus"
 version = "0.28.0-SNAPSHOT" // CURRENT_OPENCENSUS_VERSION
 
-def opencensusVersion = "0.27.0" // LATEST_OPENCENSUS_RELEASE_VERSION
-def grpcVersion = "1.22.1" // CURRENT_GRPC_VERSION
+def opencensusVersion = "0.27.1" // LATEST_OPENCENSUS_RELEASE_VERSION
+def grpcVersion = "1.32.2" // CURRENT_GRPC_VERSION
 def prometheusVersion = "0.6.0"
 def jettyVersion = "9.4.17.v20190418"
 def tcnativeVersion = "2.0.20.Final"
@@ -62,6 +62,7 @@ dependencies {
             "io.grpc:grpc-protobuf:${grpcVersion}",
             "io.grpc:grpc-stub:${grpcVersion}",
             "io.grpc:grpc-netty-shaded:${grpcVersion}",
+            "io.grpc:grpc-census:${grpcVersion}",
             "io.prometheus:simpleclient_httpserver:${prometheusVersion}",
             "javax.servlet:javax.servlet-api:3.1.0",
             "org.eclipse.jetty:jetty-server:${jettyVersion}",

examples/pom.xml

@@ -12,8 +12,8 @@
     <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     <!-- change to the version you want to use. -->
     <jetty.version>9.4.17.v20190418</jetty.version>
-    <opencensus.version>0.27.0</opencensus.version><!-- LATEST_OPENCENSUS_RELEASE_VERSION -->
-    <grpc.version>1.27.2</grpc.version><!-- CURRENT_GRPC_VERSION -->
+    <opencensus.version>0.27.1</opencensus.version> <!-- LATEST_OPENCENSUS_RELEASE_VERSION -->
+    <grpc.version>1.32.2</grpc.version> <!-- CURRENT_GRPC_VERSION -->
   </properties>
   <dependencies>
     <dependency>
@@ -29,7 +29,7 @@
     <dependency>
       <groupId>io.opencensus</groupId>
       <artifactId>opencensus-contrib-http-util</artifactId>
-       <version>${opencensus.version}</version>
+      <version>${opencensus.version}</version>
     </dependency>
     <dependency>
       <groupId>io.opencensus</groupId>
@@ -58,7 +58,7 @@
       <exclusions>
         <exclusion>
           <groupId>io.grpc</groupId>
-          <artifactId>grpc-core</artifactId>
+          <artifactId>grpc-api</artifactId>
         </exclusion>
       </exclusions>
     </dependency>
@@ -76,6 +76,12 @@
       <groupId>io.opencensus</groupId>
       <artifactId>opencensus-exporter-trace-stackdriver</artifactId>
       <version>${opencensus.version}</version>
+      <exclusions>
+        <exclusion>
+          <groupId>io.grpc</groupId>
+          <artifactId>grpc-api</artifactId>
+        </exclusion>
+      </exclusions>
     </dependency>
     <dependency>
       <groupId>io.opencensus</groupId>
@@ -112,6 +118,11 @@
       <artifactId>grpc-stub</artifactId>
       <version>${grpc.version}</version>
     </dependency>
+    <dependency>
+      <groupId>io.grpc</groupId>
+      <artifactId>grpc-census</artifactId>
+      <version>${grpc.version}</version>
+    </dependency>
     <dependency>
       <groupId>io.prometheus</groupId>
       <artifactId>simpleclient_httpserver</artifactId>
@@ -278,4 +289,3 @@
     </plugins>
   </build>
 </project>
-

examples/src/main/java/io/opencensus/examples/grpc/helloworld/HelloWorldServer.java

@@ -39,6 +39,7 @@
 import io.opencensus.trace.Status;
 import io.opencensus.trace.Tracer;
 import io.opencensus.trace.Tracing;
+import io.opencensus.trace.config.TraceConfig;
 import io.opencensus.trace.samplers.Samplers;
 import io.prometheus.client.exporter.HTTPServer;
 import java.io.IOException;
@@ -60,10 +61,7 @@ private HelloWorldServer(int serverPort) {
   // A helper function that performs some work in its own Span.
   private static void performWork(Span parent) {
     SpanBuilder spanBuilder =
-        tracer
-            .spanBuilderWithExplicitParent("internal_work", parent)
-            .setRecordEvents(true)
-            .setSampler(Samplers.alwaysSample());
+        tracer.spanBuilderWithExplicitParent("internal_work", parent).setRecordEvents(true);
     try (Scope scope = spanBuilder.startScopedSpan()) {
       Span span = tracer.getCurrentSpan();
       span.putAttribute("my_attribute", AttributeValue.stringAttributeValue("blue"));
@@ -120,6 +118,11 @@ public static void main(String[] args) throws IOException, InterruptedException
     final int zPagePort = getPortOrDefaultFromArgs(args, 2, 3000);
     final int prometheusPort = getPortOrDefaultFromArgs(args, 3, 9090);
 
+    // For demo purposes, always sample
+    TraceConfig traceConfig = Tracing.getTraceConfig();
+    traceConfig.updateActiveTraceParams(
+        traceConfig.getActiveTraceParams().toBuilder().setSampler(Samplers.alwaysSample()).build());
+
     // Registers all RPC views. For demonstration all views are registered. You may want to
     // start with registering basic views and register other views as needed for your application.
     RpcViews.registerAllViews();
@@ -138,7 +141,7 @@ public static void main(String[] args) throws IOException, InterruptedException
       StackdriverStatsExporter.createAndRegister(
           StackdriverStatsConfiguration.builder()
               .setProjectId(cloudProjectId)
-              .setExportInterval(Duration.create(60, 0))
+              .setExportInterval(Duration.create(5, 0))
               .build());
     }