From eb0f493998a704ca0002e2d54e8b7d62fb8f7f57 Mon Sep 17 00:00:00 2001 From: George Date: Wed, 24 Jul 2019 01:00:07 +0200 Subject: [PATCH] Add Start() function to DockerLogs input plugin (#6157) --- plugins/inputs/docker_log/docker_log.go | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/plugins/inputs/docker_log/docker_log.go b/plugins/inputs/docker_log/docker_log.go index 01a2f83da..f2b5b5148 100644 --- a/plugins/inputs/docker_log/docker_log.go +++ b/plugins/inputs/docker_log/docker_log.go @@ -68,6 +68,8 @@ const ( var ( containerStates = []string{"created", "restarting", "running", "removing", "paused", "exited", "dead"} + // ensure *DockerLogs implements telegaf.ServiceInput + _ telegraf.ServiceInput = (*DockerLogs)(nil) ) type DockerLogs struct { @@ -380,6 +382,12 @@ func tailMultiplexed( return err } +// Start is a noop which is required for a *DockerLogs to implement +// the telegraf.ServiceInput interface +func (d *DockerLogs) Start(telegraf.Accumulator) error { + return nil +} + func (d *DockerLogs) Stop() { d.cancelTails() d.wg.Wait()