Fix open error handling in file output (#5540)

2019-03-22 13:59:30 -07:00
parent fa65a82ef3
commit 99a390b8e6
3 changed files with 17 additions and 23 deletions
--- a/internal/models/running_output.go
+++ b/internal/models/running_output.go
@@ -180,6 +180,13 @@ func (ro *RunningOutput) WriteBatch() error {
 	return nil
 }

+func (ro *RunningOutput) Close() {
+	err := ro.Output.Close()
+	if err != nil {
+		log.Printf("E! [outputs.%s] Error closing output: %v", ro.Name, err)
+	}
+}
+
 func (ro *RunningOutput) write(metrics []telegraf.Metric) error {
 	start := time.Now()
 	err := ro.Output.Write(metrics)