Good morning all,
I am new to all of this and been thrown in the deep end to understanding an existing setup.
Currently we have a go script which monitors folders for files and upon identifying the files processes these through a libbeat to a logstash server. The process works great, however i wish to look at monitoring the libbeats returned signal from the [publisher], in particular the:
DEBUG [publisher] memqueue/ackloop.go:131 ackloop: done send ack
That way i can acknowledge when the file has been completed at the logstash end.
Reading all the documentation and searching for anything related to this is coming up blank and a bit stuck on where to look.
The current script calls upon the '.Publisher.Connect()' to create the initial connection and looking through certain documents they mention utilizing ACKCount, but after searching this i am none the wiser. If anyone is able to point me in the right direction would be greatly appreciated.