diff options
| author | Jakob Odersky <jakob@driver.xyz> | 2017-10-02 16:08:24 -0700 |
|---|---|---|
| committer | Jakob Odersky <jakob@driver.xyz> | 2017-10-02 16:08:24 -0700 |
| commit | df2c41dac7d29dea49950700b0146229947fdf65 (patch) | |
| tree | d5e09ac2d1f1527e965f92d5733a5761acf8edb1 /src/main/scala/GoogleTracer.scala | |
| parent | 7f4a7648894be1f07300f6d66f00ff443dc83826 (diff) | |
| download | tracing-df2c41dac7d29dea49950700b0146229947fdf65.tar.gz tracing-df2c41dac7d29dea49950700b0146229947fdf65.tar.bz2 tracing-df2c41dac7d29dea49950700b0146229947fdf65.zip | |
Minor style changes
Diffstat (limited to 'src/main/scala/GoogleTracer.scala')
| -rw-r--r-- | src/main/scala/GoogleTracer.scala | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/main/scala/GoogleTracer.scala b/src/main/scala/GoogleTracer.scala index 42fb9fd..144c0ff 100644 --- a/src/main/scala/GoogleTracer.scala +++ b/src/main/scala/GoogleTracer.scala @@ -17,7 +17,8 @@ import scala.util.control._ class GoogleTracer(projectId: String, serviceAccountFile: Path, bufferSize: Int = 1000, - concurrentConnections: Int = 1)(implicit system: ActorSystem, + bufferDelay: FiniteDuration = 2.seconds, + concurrentConnections: Int = 5)(implicit system: ActorSystem, materializer: Materializer) extends Tracer { @@ -27,7 +28,7 @@ class GoogleTracer(projectId: String, private val batchingPipeline: Flow[Span, Traces, _] = Flow[Span] - .groupedWithin(bufferSize, 1.second) + .groupedWithin(bufferSize, bufferDelay) .map { spans => val traces: Seq[Trace] = spans .groupBy(_.traceId) |