initial commit (#1799)

Author: Michael Hoffmann

exporters/trace/jaeger/src/main/java/io/opencensus/exporter/trace/jaeger/JaegerExporterHandler.java

@@ -26,7 +26,7 @@
 import com.google.common.primitives.Longs;
 import com.google.errorprone.annotations.MustBeClosed;
 import io.jaegertracing.internal.exceptions.SenderException;
-import io.jaegertracing.thrift.internal.senders.HttpSender;
+import io.jaegertracing.thrift.internal.senders.ThriftSender;
 import io.jaegertracing.thriftjava.Log;
 import io.jaegertracing.thriftjava.Process;
 import io.jaegertracing.thriftjava.Span;
@@ -150,10 +150,10 @@ public Tag apply(final Object value) {
   private final byte[] traceIdBuffer = new byte[TraceId.SIZE];
   private final byte[] optionsBuffer = new byte[Integer.SIZE / Byte.SIZE];
 
-  private final HttpSender sender;
+  private final ThriftSender sender;
   private final Process process;
 
-  JaegerExporterHandler(final HttpSender sender, final Process process) {
+  JaegerExporterHandler(final ThriftSender sender, final Process process) {
     this.sender = checkNotNull(sender, "Jaeger sender must NOT be null.");
     this.process = checkNotNull(process, "Process sending traces must NOT be null.");
   }

exporters/trace/jaeger/src/main/java/io/opencensus/exporter/trace/jaeger/JaegerTraceExporter.java

@@ -20,6 +20,7 @@
 
 import com.google.common.annotations.VisibleForTesting;
 import io.jaegertracing.thrift.internal.senders.HttpSender;
+import io.jaegertracing.thrift.internal.senders.ThriftSender;
 import io.jaegertracing.thriftjava.Process;
 import io.opencensus.trace.Tracing;
 import io.opencensus.trace.export.SpanExporter;
@@ -72,15 +73,15 @@ public static void createAndRegister(final String thriftEndpoint, final String s
    * Creates and registers the Jaeger Trace exporter to the OpenCensus library using the provided
    * HttpSender. Only one Jaeger exporter can be registered at any point.
    *
-   * @param httpSender the pre-configured HttpSender to use with the exporter
+   * @param sender the pre-configured ThriftSender to use with the exporter
    * @param serviceName the local service name of the process.
    * @throws IllegalStateException if a Jaeger exporter is already registered.
    * @since 0.17
    */
-  public static void createWithSender(final HttpSender httpSender, final String serviceName) {
+  public static void createWithSender(final ThriftSender sender, final String serviceName) {
     synchronized (monitor) {
       checkState(handler == null, "Jaeger exporter is already registered.");
-      final SpanExporter.Handler newHandler = newHandlerWithSender(httpSender, serviceName);
+      final SpanExporter.Handler newHandler = newHandlerWithSender(sender, serviceName);
       JaegerTraceExporter.handler = newHandler;
       register(Tracing.getExportComponent().getSpanExporter(), newHandler);
     }
@@ -94,7 +95,7 @@ private static SpanExporter.Handler newHandler(
   }
 
   private static SpanExporter.Handler newHandlerWithSender(
-      final HttpSender sender, final String serviceName) {
+      final ThriftSender sender, final String serviceName) {
     final Process process = new Process(serviceName);
     return new JaegerExporterHandler(sender, process);
   }