From 3e5176a79c56b9953c07a29e05ce492f43aa5ab5 Mon Sep 17 00:00:00 2001
From: Bradley Cicenas <bradley@vektor.nyc>
Date: Tue, 28 Nov 2017 14:36:28 +0000
Subject: [PATCH] add NewDockerLogs constructor method

---
 connector/collector/docker.go      | 2 +-
 connector/collector/docker_logs.go | 8 ++++++++
 2 files changed, 9 insertions(+), 1 deletion(-)

diff --git a/connector/collector/docker.go b/connector/collector/docker.go
index 07bcff3..12006b4 100644
--- a/connector/collector/docker.go
+++ b/connector/collector/docker.go
@@ -66,7 +66,7 @@ func (c *Docker) Stream() chan models.Metrics {
 }
 
 func (c *Docker) Logs() LogCollector {
-	return &DockerLogs{c.id, c.client, make(chan bool)}
+	return NewDockerLogs(c.id, c.client)
 }
 
 // Stop collector
diff --git a/connector/collector/docker_logs.go b/connector/collector/docker_logs.go
index 4a8946e..f350d36 100644
--- a/connector/collector/docker_logs.go
+++ b/connector/collector/docker_logs.go
@@ -17,6 +17,14 @@ type DockerLogs struct {
 	done   chan bool
 }
 
+func NewDockerLogs(id string, client *api.Client) *DockerLogs {
+	return &DockerLogs{
+		id:     id,
+		client: client,
+		done:   make(chan bool),
+	}
+}
+
 func (l *DockerLogs) Stream() chan models.Log {
 	r, w := io.Pipe()
 	logCh := make(chan models.Log)