Fix leaking go routine in docker stats fetching

CHANGELOG.asciidoc

@@ -37,6 +37,7 @@ https://github.com/elastic/beats/compare/v5.1.1...master[Check the HEAD diff]
 - Kafka module case sensitive host name matching. {pull}3193[3193]
 - Fix interface conversion panic in couchbase module {pull}3272[3272]
 - Fix overwriting explicit empty config sections {issue}2918[2918]
+- Fix go routine leak in docker module. {pull}3492[3492]
 
 *Packetbeat*
 

metricbeat/module/docker/docker.go

@@ -66,24 +66,26 @@ func FetchStats(client *docker.Client) ([]Stat, error) {
 
 	var wg sync.WaitGroup
 
-	containersList := []Stat{}
+	containersList := make([]Stat, 0, len(containers))
 	queue := make(chan Stat, 1)
 	wg.Add(len(containers))
 
 	for _, container := range containers {
 		go func(container docker.APIContainers) {
+			defer wg.Done()
 			queue <- exportContainerStats(client, &container)
 		}(container)
 	}
 
 	go func() {
-		for container := range queue {
-			containersList = append(containersList, container)
-			wg.Done()
-		}
+		wg.Wait()
+		close(queue)
 	}()
 
-	wg.Wait()
+	// This will break after the queue has been drained and queue is closed.
+	for container := range queue {
+		containersList = append(containersList, container)
+	}
 
 	return containersList, err
 }