From 8a68e7424c48e8f28034855a239265ab52ba536d Mon Sep 17 00:00:00 2001
From: Daniel Nelson <daniel.nelson@influxdb.com>
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 ba8dba80..c9996074 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)) {
--
GitLab