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 --- .../driver/core/trace/GoogleStackdriverTraceWithConsumer.scala | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) (limited to 'src/main/scala/xyz/driver/core/trace/GoogleStackdriverTraceWithConsumer.scala') diff --git a/src/main/scala/xyz/driver/core/trace/GoogleStackdriverTraceWithConsumer.scala b/src/main/scala/xyz/driver/core/trace/GoogleStackdriverTraceWithConsumer.scala index 81619d2..13b80bb 100644 --- a/src/main/scala/xyz/driver/core/trace/GoogleStackdriverTraceWithConsumer.scala +++ b/src/main/scala/xyz/driver/core/trace/GoogleStackdriverTraceWithConsumer.scala @@ -16,12 +16,13 @@ final class GoogleStackdriverTraceWithConsumer(projectId: String, appName: String, appEnvironment: String, traceConsumer: TraceConsumer, - log: Logger) + log: Logger, + bufferSize: Int) extends GoogleServiceTracer { private val traceProducer: TraceProducer = new TraceProducer() private val threadSafeBufferingTraceConsumer = new ExceptionLoggingFlushableTraceConsumer( - new SizedBufferingTraceConsumer(traceConsumer, new RoughTraceSizer(), 100), + new SizedBufferingTraceConsumer(traceConsumer, new RoughTraceSizer(), bufferSize), log ) @@ -73,7 +74,8 @@ final class GoogleStackdriverTraceWithConsumer(projectId: String, override def endSpan(span: TracerSpanPayload): Unit = { span.tracer.endSpan(span.context) - threadSafeBufferingTraceConsumer.flush() // flush out the thread safe buffer } + override def flush(): Unit = threadSafeBufferingTraceConsumer.flush() // flush out the thread safe buffer + } -- cgit v1.2.3