1 files changed, 0 insertions, 95 deletions
diff --git a/src/main/scala/xyz/driver/core/trace/GoogleStackdriverTraceWithConsumer.scala b/src/main/scala/xyz/driver/core/trace/GoogleStackdriverTraceWithConsumer.scala
deleted file mode 100644
index ca1eab2..0000000
--- a/src/main/scala/xyz/driver/core/trace/GoogleStackdriverTraceWithConsumer.scala
+++ /dev/null
@@ -1,95 +0,0 @@
-package xyz.driver.core.trace
-
-import akka.http.scaladsl.model.HttpRequest
-import com.google.cloud.trace.core._
-import com.google.cloud.trace.sink.TraceSink
-import com.google.cloud.trace.v1.TraceSinkV1
-import com.google.cloud.trace.v1.consumer.{ScheduledBufferingTraceConsumer, TraceConsumer}
-import com.google.cloud.trace.v1.producer.TraceProducer
-import com.google.cloud.trace.{SpanContextHandler, SpanContextHandlerTracer, Tracer}
-import com.typesafe.scalalogging.Logger
-import java.util.concurrent.ScheduledThreadPoolExecutor
-import java.util.concurrent.TimeUnit
-
-import scala.compat.java8.OptionConverters._
-
-final class GoogleStackdriverTraceWithConsumer(projectId: String,
-                                               appName: String,
-                                               appEnvironment: String,
-                                               traceConsumer: TraceConsumer,
-                                               log: Logger,
-                                               bufferSize: Int,
-                                               scheduledDelay: Int)
-    extends GoogleServiceTracer {
-
-  private val traceProducer: TraceProducer = new TraceProducer()
-  // use a UnitTraceSizer so the interpretation of bufferSize is # of spans to hold in memory prior to flushing
-
-  // now set up the scheduled executor for time-based flushing of our tracing
-  // see https://goo.gl/HrPLuC
-  private val scheduledThreadPoolExecutor = new ScheduledThreadPoolExecutor(1) // this is just used for it's timing execution
-  scheduledThreadPoolExecutor.setKeepAliveTime(scheduledDelay.toLong, TimeUnit.SECONDS)
-  scheduledThreadPoolExecutor.allowCoreThreadTimeOut(true)
-  private val executorService = scheduledThreadPoolExecutor
-  private val threadSafeBufferingTraceConsumer = new ExceptionLoggingFlushableTraceConsumer(
-    new ScheduledBufferingTraceConsumer(traceConsumer,
-                                        new UnitTraceSizer(),
-                                        bufferSize,
-                                        scheduledDelay,
-                                        executorService),
-    log
-  )
-
-  private val traceSink: TraceSink = new TraceSinkV1(projectId, traceProducer, threadSafeBufferingTraceConsumer)
-
-  private val spanContextFactory: SpanContextFactory = new SpanContextFactory(
-    new ConstantTraceOptionsFactory(true, true))
-  private val timestampFactory: TimestampFactory = new JavaTimestampFactory()
-
-  override def startSpan(httpRequest: HttpRequest): TracerSpanPayload = {
-    val parentHeaderOption: Option[akka.http.javadsl.model.HttpHeader] =
-      httpRequest.getHeader(TracingHeaderKey).asScala
-    val (spanContext: SpanContext, spanKind: SpanKind) = parentHeaderOption.fold {
-      (spanContextFactory.initialContext(), SpanKind.RPC_CLIENT)
-    } { parentHeader =>
-      (spanContextFactory.fromHeader(parentHeader.value()), SpanKind.RPC_SERVER)
-    }
-
-    val contextHandler: SpanContextHandler = new SimpleSpanContextHandler(spanContext)
-    val httpMethod                         = httpRequest.method.value
-    val httpHost                           = httpRequest.uri.authority.host.address()
-    val httpRelative                       = httpRequest.uri.toRelative.toString()
-    val tracer: Tracer                     = new SpanContextHandlerTracer(traceSink, contextHandler, spanContextFactory, timestampFactory)
-    // Create a span using the given timestamps.
-    // https://cloud.google.com/trace/docs/reference/v1/rest/v1/projects.traces#TraceSpan
-    val spanOptions: StartSpanOptions = (new StartSpanOptions()).setSpanKind(spanKind)
-
-    val spanLabelBuilder = Labels
-      .builder()
-      .add("/http/method", httpMethod)
-      .add("/http/url", httpRelative)
-      .add("/http/host", httpHost)
-      .add("/component", appName)
-      .add("/environment", appEnvironment)
-
-    parentHeaderOption.foreach { parentHeader =>
-      spanLabelBuilder.add("/span/parent", parentHeader.value())
-    }
-
-    // The cloudTrace analysis reporting UI makes it easy to query by name prefix.
-    // this spanName gives us the ability to grab things that are specific to a particular UDE/env, as well as all
-    // endpoints in that service, as well as a particular endpoint in a particular environment/service.
-    val spanName: String = s"($appEnvironment->$appName)$httpRelative"
-
-    val context: TraceContext = tracer.startSpan(spanName, spanOptions)
-    tracer.annotateSpan(context, spanLabelBuilder.build())
-    GoogleStackdriverTraceSpan(tracer, context)
-  }
-
-  override def endSpan(span: TracerSpanPayload): Unit = {
-    span.tracer.endSpan(span.context)
-  }
-
-  override def flush(): Unit = threadSafeBufferingTraceConsumer.flush() // flush out the thread safe buffer
-
-}