The diskqueue calls paths.Resolve to determine where the disk queue should exist on the filesystem.
|
return paths.Resolve(paths.Data, "diskqueue") |
This should be modified to use:
|
Paths *paths.Path // per beat paths definition |
Currently for beatreceivers we don't support the diskqueue, but this should still be fixed so that beat receivers would get the correct queue on restarts.
Relates #44903
The diskqueue calls
paths.Resolveto determine where the disk queue should exist on the filesystem.beats/libbeat/publisher/queue/diskqueue/config.go
Line 175 in e1d92eb
This should be modified to use:
beats/libbeat/beat/beat.go
Line 92 in 78caa87
Currently for beatreceivers we don't support the diskqueue, but this should still be fixed so that beat receivers would get the correct queue on restarts.
Relates #44903