aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/xyz/driver/core/trace/LoggingTrace.scala
diff options
context:
space:
mode:
authorJohn St John <johnthesaintjohn@gmail.com>2017-10-04 10:39:21 -0700
committerJohn St John <johnthesaintjohn@gmail.com>2017-10-04 10:39:21 -0700
commitcacf57dc4af5b0104b28b6417715c660aef613f3 (patch)
tree111f9973b559cd88fcf910c780b2821268add6af /src/main/scala/xyz/driver/core/trace/LoggingTrace.scala
parent16d2b4c6b4d230681cae45d2c2557a4cd46439a2 (diff)
downloaddriver-core-cacf57dc4af5b0104b28b6417715c660aef613f3.tar.gz
driver-core-cacf57dc4af5b0104b28b6417715c660aef613f3.tar.bz2
driver-core-cacf57dc4af5b0104b28b6417715c660aef613f3.zip
Follow google example to implement a scheduled flusing trace consumer by default
Diffstat (limited to 'src/main/scala/xyz/driver/core/trace/LoggingTrace.scala')
-rw-r--r--src/main/scala/xyz/driver/core/trace/LoggingTrace.scala5
1 files changed, 3 insertions, 2 deletions
diff --git a/src/main/scala/xyz/driver/core/trace/LoggingTrace.scala b/src/main/scala/xyz/driver/core/trace/LoggingTrace.scala
index cd920f0..6a13708 100644
--- a/src/main/scala/xyz/driver/core/trace/LoggingTrace.scala
+++ b/src/main/scala/xyz/driver/core/trace/LoggingTrace.scala
@@ -4,7 +4,7 @@ import akka.http.scaladsl.model.HttpRequest
import com.google.cloud.trace.v1.consumer.TraceConsumer
import com.typesafe.scalalogging.Logger
-final class LoggingTrace(appName: String, appEnvironment: String, log: Logger, bufferSize: Int)
+final class LoggingTrace(appName: String, appEnvironment: String, log: Logger, bufferSize: Int, scheduledDelay: Int)
extends GoogleServiceTracer {
private val traceConsumer: TraceConsumer = new LoggingTraceConsumer(log)
@@ -14,7 +14,8 @@ final class LoggingTrace(appName: String, appEnvironment: String, log: Logger, b
appEnvironment,
traceConsumer,
log,
- bufferSize
+ bufferSize,
+ scheduledDelay
)
override def startSpan(httpRequest: HttpRequest): GoogleStackdriverTraceSpan =