From 99be3b979e41333c6ae1fb620cc6dc484ff156f4 Mon Sep 17 00:00:00 2001
From: Frol Kryuchkov <fkruchkov@avito.ru>
Date: Fri, 11 Jun 2021 17:22:34 +0300
Subject: [PATCH] #254-handling-with-wrong-log-format

---
 connector/collector/docker_logs.go | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/connector/collector/docker_logs.go b/connector/collector/docker_logs.go
index d8b7559..124095c 100644
--- a/connector/collector/docker_logs.go
+++ b/connector/collector/docker_logs.go
@@ -48,8 +48,14 @@ func (l *DockerLogs) Stream() chan models.Log {
 		scanner := bufio.NewScanner(r)
 		for scanner.Scan() {
 			parts := strings.SplitN(scanner.Text(), " ", 2)
-			ts := l.parseTime(parts[0])
-			logCh <- models.Log{Timestamp: ts, Message: parts[1]}
+			if len(parts) == 0 {
+				continue
+			}
+			if len(parts) < 2 {
+				logCh <- models.Log{Timestamp: l.parseTime(""), Message: parts[0]}
+			} else {
+				logCh <- models.Log{Timestamp: l.parseTime(parts[0]), Message: parts[1]}
+			}
 		}
 	}()