cache messages for a short time and send as a package

alpha v1.0.51
alex 2023-02-19 18:59:40 +01:00
parent 93ae6cb5d4
commit aad13ba023
1 changed files with 6 additions and 0 deletions

View File

@ -169,6 +169,12 @@ func startLogMessagesSender() {
for range ticker.C {
log.Print("tick")
msgs := getLogMessages()
if len(msgs) == 0 {
continue
}
if err := logsClient.PushQueueMessage(getLogMessages()); err != nil {
log.Error().Msgf("Failed to push log message, err: %s", err)
continue