We wanted to use TCP to stream all our log messages in one connection to reduce the overhead on our application, however protologbeat only handles the first message by default. By wrapping the Unmarshal call in a bufio.Scanner we can parse one json message per line, allowing for an unlimited number of logs to be sent in one TCP stream.
This should also resolve issue #15, assuming they want to use json as the message format.
We wanted to use TCP to stream all our log messages in one connection to reduce the overhead on our application, however protologbeat only handles the first message by default. By wrapping the
Unmarshalcall in abufio.Scannerwe can parse one json message per line, allowing for an unlimited number of logs to be sent in one TCP stream.This should also resolve issue #15, assuming they want to use json as the message format.