From cacf57dc4af5b0104b28b6417715c660aef613f3 Mon Sep 17 00:00:00 2001
From: John St John <johnthesaintjohn@gmail.com>
Date: Wed, 4 Oct 2017 10:39:21 -0700
Subject: Follow google example to implement a scheduled flusing trace consumer
 by default

---
 .../scala/xyz/driver/core/trace/GoogleStackdriverTrace.scala  | 11 +++++++++--
 1 file changed, 9 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 ce84f9d..fe4bb5c 100644
--- a/src/main/scala/xyz/driver/core/trace/GoogleStackdriverTrace.scala
+++ b/src/main/scala/xyz/driver/core/trace/GoogleStackdriverTrace.scala
@@ -15,7 +15,8 @@ final class GoogleStackdriverTrace(projectId: String,
                                    appName: String,
                                    appEnvironment: String,
                                    log: Logger,
-                                   bufferSize: Int = 10)
+                                   bufferSize: Int = 1024,
+                                   scheduledDelay: Int = 15)
     extends GoogleServiceTracer {
 
   // initialize our various tracking storage systems
@@ -38,7 +39,13 @@ final class GoogleStackdriverTrace(projectId: String,
   }
 
   private val googleServiceTracer =
-    new GoogleStackdriverTraceWithConsumer(projectId, appName, appEnvironment, traceConsumer, log, bufferSize)
+    new GoogleStackdriverTraceWithConsumer(projectId,
+                                           appName,
+                                           appEnvironment,
+                                           traceConsumer,
+                                           log,
+                                           bufferSize,
+                                           scheduledDelay)
 
   override def startSpan(httpRequest: HttpRequest): GoogleStackdriverTraceSpan =
     googleServiceTracer.startSpan(httpRequest)
-- 
cgit v1.2.3