Return new Syslog instance for each plugin (#5372)

2019-02-04 11:21:16 -08:00
parent 6b144db504
commit 00734c56c4
1 changed files with 12 additions and 12 deletions
--- a/plugins/inputs/syslog/syslog.go
+++ b/plugins/inputs/syslog/syslog.go
@@ -438,16 +438,16 @@ func getNanoNow() time.Time {
 }

 func init() {
-	receiver := &Syslog{
-		Address: ":6514",
-		now:     getNanoNow,
-		ReadTimeout: &internal.Duration{
-			Duration: defaultReadTimeout,
-		},
-		Framing:   OctetCounting,
-		Trailer:   nontransparent.LF,
-		Separator: "_",
-	}
-
-	inputs.Add("syslog", func() telegraf.Input { return receiver })
+	inputs.Add("syslog", func() telegraf.Input {
+		return &Syslog{
+			Address: ":6514",
+			now:     getNanoNow,
+			ReadTimeout: &internal.Duration{
+				Duration: defaultReadTimeout,
+			},
+			Framing:   OctetCounting,
+			Trailer:   nontransparent.LF,
+			Separator: "_",
+		}
+	})
 }