From c1628abaad79de60c7eafb27a5914dabd3fb75dc Mon Sep 17 00:00:00 2001 From: John St John Date: Tue, 26 Sep 2017 17:03:32 -0700 Subject: only push traces every 10 requests by default --- src/main/scala/xyz/driver/core/trace/GoogleStackdriverTrace.scala | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) (limited to 'src/main/scala/xyz/driver/core/trace/GoogleStackdriverTrace.scala') diff --git a/src/main/scala/xyz/driver/core/trace/GoogleStackdriverTrace.scala b/src/main/scala/xyz/driver/core/trace/GoogleStackdriverTrace.scala index fa98ef4..04f2ec6 100644 --- a/src/main/scala/xyz/driver/core/trace/GoogleStackdriverTrace.scala +++ b/src/main/scala/xyz/driver/core/trace/GoogleStackdriverTrace.scala @@ -14,7 +14,8 @@ final class GoogleStackdriverTrace(projectId: String, clientSecretsFile: String, appName: String, appEnvironment: String, - log: Logger) + log: Logger, + bufferSize: Int = 10) extends GoogleServiceTracer { // initialize our various tracking storage systems @@ -38,10 +39,12 @@ final class GoogleStackdriverTrace(projectId: String, } private val googleServiceTracer = - new GoogleStackdriverTraceWithConsumer(projectId, appName, appEnvironment, traceConsumer, log) + new GoogleStackdriverTraceWithConsumer(projectId, appName, appEnvironment, traceConsumer, log, bufferSize) override def startSpan(httpRequest: HttpRequest): GoogleStackdriverTraceSpan = googleServiceTracer.startSpan(httpRequest) override def endSpan(span: GoogleStackdriverTraceSpan): Unit = googleServiceTracer.endSpan(span) + + override def flush(): Unit = googleServiceTracer.flush() } -- cgit v1.2.3