aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/GoogleTracer.scala
diff options
context:
space:
mode:
authorJakob Odersky <jakob@driver.xyz>2017-10-01 23:15:12 -0700
committerJakob Odersky <jakob@driver.xyz>2017-10-01 23:15:12 -0700
commit774864100676b7dbcf332f40c833cfa65dcd7b5a (patch)
tree820462a4b57aaa7647075b0a9495f05443672a0f /src/main/scala/GoogleTracer.scala
parent2c08b51411be5b0cce57f876377fcd52bee99990 (diff)
downloadtracing-774864100676b7dbcf332f40c833cfa65dcd7b5a.tar.gz
tracing-774864100676b7dbcf332f40c833cfa65dcd7b5a.tar.bz2
tracing-774864100676b7dbcf332f40c833cfa65dcd7b5a.zip
Fix google tracing long and date format
Diffstat (limited to 'src/main/scala/GoogleTracer.scala')
-rw-r--r--src/main/scala/GoogleTracer.scala3
1 files changed, 0 insertions, 3 deletions
diff --git a/src/main/scala/GoogleTracer.scala b/src/main/scala/GoogleTracer.scala
index 5b3c9df..7ffd356 100644
--- a/src/main/scala/GoogleTracer.scala
+++ b/src/main/scala/GoogleTracer.scala
@@ -47,10 +47,8 @@ class GoogleTracer(projectId: String,
lazy val queue: SourceQueueWithComplete[Span] = {
Source
.queue[Span](bufferSize, OverflowStrategy.dropNew)
- .log("debug")
.viaMat(batchingPipeline)(Keep.left)
.mapAsync(concurrentConnections) { (traces: Traces) =>
- println(traces)
Marshal(traces).to[RequestEntity].map { entity =>
HttpRequest(
method = HttpMethods.PATCH,
@@ -72,7 +70,6 @@ class GoogleTracer(projectId: String,
.mapError {
case NonFatal(e) =>
system.log.error(s"Exception encountered while submitting trace", e)
- e.printStackTrace
e
}
.to(Sink.ignore)