From 29e71310f3f275def3e07d257901b6e89ad0818e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Juraci=20Paix=C3=A3o=20Kr=C3=B6hling?= Date: Fri, 7 Feb 2020 10:07:31 +0100 Subject: [PATCH] Use memory size flag to activate dyn queue size feature (#2059) MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Juraci Paixão Kröhling --- cmd/collector/app/span_processor.go | 2 +- cmd/collector/app/span_processor_test.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/cmd/collector/app/span_processor.go b/cmd/collector/app/span_processor.go index 3027932bfb9..3a77cd3b86a 100644 --- a/cmd/collector/app/span_processor.go +++ b/cmd/collector/app/span_processor.go @@ -125,7 +125,7 @@ func newSpanProcessor(spanWriter spanstore.Writer, opts ...Option) *spanProcesso } processSpanFuncs := []ProcessSpan{options.preSave, sp.saveSpan} - if options.dynQueueSizeWarmup > 0 { + if options.dynQueueSizeMemory > 0 { // add to processSpanFuncs options.logger.Info("Dynamically adjusting the queue size at runtime.", zap.Uint("memory-mib", options.dynQueueSizeMemory/1024/1024), diff --git a/cmd/collector/app/span_processor_test.go b/cmd/collector/app/span_processor_test.go index 426aa582820..fc0c9d01ea8 100644 --- a/cmd/collector/app/span_processor_test.go +++ b/cmd/collector/app/span_processor_test.go @@ -353,7 +353,7 @@ func TestSpanProcessorCountSpan(t *testing.T) { m := mb.Namespace(metrics.NSOptions{}) w := &fakeSpanWriter{} - p := NewSpanProcessor(w, Options.HostMetrics(m), Options.DynQueueSizeWarmup(1000)).(*spanProcessor) + p := NewSpanProcessor(w, Options.HostMetrics(m), Options.DynQueueSizeMemory(1000)).(*spanProcessor) p.background(10*time.Millisecond, p.updateGauges) defer p.Stop()