diff --git a/filebeat/prospector/prospector.go b/filebeat/prospector/prospector.go index 93277430b04..6cca988b14b 100644 --- a/filebeat/prospector/prospector.go +++ b/filebeat/prospector/prospector.go @@ -21,6 +21,7 @@ var ( ) type Prospector struct { + harvesterCounter uint64 // Must be 8-byte aligned. Ensured if first field in struct cfg *common.Config // Raw config config prospectorConfig prospectorer Prospectorer @@ -30,7 +31,8 @@ type Prospector struct { states *file.States wg sync.WaitGroup channelWg sync.WaitGroup // Separate waitgroup for channels as not stopped on completion - harvesterCounter uint64 + ID uint64 + Once bool } type Prospectorer interface {