[metricbeat] check for a valid limit before we process a memory event (…

…#11676)

* check for a valid limit before we process a memory event

CHANGELOG.next.asciidoc

@@ -76,6 +76,7 @@ https://github.com/elastic/beats/compare/v7.0.0-alpha2...master[Check the HEAD d
 *Metricbeat*
 
 - Add _bucket to histogram metrics in Prometheus Collector {pull}11578[11578]
+- Prevent the docker/memory metricset from processing invalid events before container start {pull}11676[11676]
 
 *Packetbeat*
 

metricbeat/module/docker/memory/helper.go

@@ -22,6 +22,7 @@ import (
 	"github.com/elastic/beats/metricbeat/module/docker"
 )
 
+// MemoryData contains parsed container memory info
 type MemoryData struct {
 	Time      common.Time
 	Container *docker.Container
@@ -34,12 +35,19 @@ type MemoryData struct {
 	UsageP    float64
 }
 
+// MemoryService is placeholder for the the memory stat parsers
 type MemoryService struct{}
 
-func (s *MemoryService) getMemoryStatsList(rawStats []docker.Stat, dedot bool) []MemoryData {
+func (s *MemoryService) getMemoryStatsList(containers []docker.Stat, dedot bool) []MemoryData {
 	formattedStats := []MemoryData{}
-	for _, myRawStats := range rawStats {
-		formattedStats = append(formattedStats, s.getMemoryStats(myRawStats, dedot))
+	for _, containerStats := range containers {
+		//There appears to be a race where a container will report with a stat object before it actually starts
+		//during this time, there doesn't appear to be any meaningful data,
+		// and Limit will never be 0 unless the container is not running & there's no cgroup data
+		if containerStats.Stats.MemoryStats.Limit == 0 {
+			continue
+		}
+		formattedStats = append(formattedStats, s.getMemoryStats(containerStats, dedot))
 	}
 
 	return formattedStats

metricbeat/module/docker/memory/memory.go

@@ -32,6 +32,7 @@ func init() {
 	)
 }
 
+// MetricSet type defines all fields of the MetricSet
 type MetricSet struct {
 	mb.BaseMetricSet
 	memoryService *MemoryService