From 4d247f52721a77471ad5d7189f052f68372fbd49 Mon Sep 17 00:00:00 2001 From: bartfokker Date: Thu, 25 Oct 2018 22:17:05 +0200 Subject: [PATCH] replace unkeyed fiels with keyed fields when instantiating log struct --- connector/collector/docker_logs.go | 2 +- connector/collector/mock_logs.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/connector/collector/docker_logs.go b/connector/collector/docker_logs.go index ae3d4a9..d5e010d 100644 --- a/connector/collector/docker_logs.go +++ b/connector/collector/docker_logs.go @@ -48,7 +48,7 @@ func (l *DockerLogs) Stream() chan models.Log { for scanner.Scan() { parts := strings.Split(scanner.Text(), " ") ts := l.parseTime(parts[0]) - logCh <- models.Log{ts, strings.Join(parts[1:], " ")} + logCh <- models.Log{Timestamp: ts, Message: strings.Join(parts[1:], " ")} } }() diff --git a/connector/collector/mock_logs.go b/connector/collector/mock_logs.go index fc79463..1b9fc1f 100644 --- a/connector/collector/mock_logs.go +++ b/connector/collector/mock_logs.go @@ -20,7 +20,7 @@ func (l *MockLogs) Stream() chan models.Log { case <-l.done: break default: - logCh <- models.Log{time.Now(), mockLog} + logCh <- models.Log{Timestamp: time.Now(), Message: mockLog} time.Sleep(250 * time.Millisecond) } }