From aa5c5dfd871c451f2712f31d9c8d0dd0d606be3a Mon Sep 17 00:00:00 2001 From: Daniel Nelson Date: Tue, 12 Sep 2017 17:15:19 -0700 Subject: [PATCH] Fix optional field types in fluentd input --- plugins/inputs/fluentd/fluentd.go | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/plugins/inputs/fluentd/fluentd.go b/plugins/inputs/fluentd/fluentd.go index ba8dba802..c99960740 100644 --- a/plugins/inputs/fluentd/fluentd.go +++ b/plugins/inputs/fluentd/fluentd.go @@ -148,15 +148,15 @@ func (h *Fluentd) Gather(acc telegraf.Accumulator) error { } if p.BufferQueueLength != nil { - tmpFields["buffer_queue_length"] = p.BufferQueueLength + tmpFields["buffer_queue_length"] = *p.BufferQueueLength } if p.RetryCount != nil { - tmpFields["retry_count"] = p.RetryCount + tmpFields["retry_count"] = *p.RetryCount } if p.BufferTotalQueuedSize != nil { - tmpFields["buffer_total_queued_size"] = p.BufferTotalQueuedSize + tmpFields["buffer_total_queued_size"] = *p.BufferTotalQueuedSize } if !((p.BufferQueueLength == nil) && (p.RetryCount == nil) && (p.BufferTotalQueuedSize == nil)) {