aboutsummaryrefslogtreecommitdiff
path: root/src/main/scala/xyz/driver/core/trace/GoogleStackdriverTrace.scala
diff options
context:
space:
mode:
authorJohn St. John <jstjohn@users.noreply.github.com>2017-10-04 11:42:12 -0700
committerGitHub <noreply@github.com>2017-10-04 11:42:12 -0700
commitdb83f93f8e63211b538d371f83c780fc01239770 (patch)
tree3669114fb81f5dbea1cd0a3afd346368a358c931 /src/main/scala/xyz/driver/core/trace/GoogleStackdriverTrace.scala
parent16d2b4c6b4d230681cae45d2c2557a4cd46439a2 (diff)
parent7b0a36d7326e9f3581d83a11dbf18515e3ddb2f1 (diff)
downloaddriver-core-db83f93f8e63211b538d371f83c780fc01239770.tar.gz
driver-core-db83f93f8e63211b538d371f83c780fc01239770.tar.bz2
driver-core-db83f93f8e63211b538d371f83c780fc01239770.zip
Merge pull request #71 from drivergroup/jstjohn/scheduled-trace-flusing-with-large-bufferv1.3.0
Scheduled flush of our trace buffer (and make it bigger)
Diffstat (limited to 'src/main/scala/xyz/driver/core/trace/GoogleStackdriverTrace.scala')
-rw-r--r--src/main/scala/xyz/driver/core/trace/GoogleStackdriverTrace.scala11
1 files changed, 9 insertions, 2 deletions
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)