From b82aff121068e4c1cd16b968723bc2e631dd360d Mon Sep 17 00:00:00 2001
From: Bryan Boreham <bjboreham@gmail.com>
Date: Sun, 14 Oct 2018 15:24:34 +0000
Subject: [PATCH] Discard pod updates for other nodes

We were filtering pods to those on the local node already, for regular
reports, so we should also filter events that come in asynchronously.
---
 probe/kubernetes/reporter.go | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/probe/kubernetes/reporter.go b/probe/kubernetes/reporter.go
index 3dfa8c793..dffccfdf5 100644
--- a/probe/kubernetes/reporter.go
+++ b/probe/kubernetes/reporter.go
@@ -193,6 +193,10 @@ func (r *Reporter) Stop() {
 func (Reporter) Name() string { return "K8s" }
 
 func (r *Reporter) podEvent(e Event, pod Pod) {
+	// filter out non-local pods, if we have been given a node name to report on
+	if r.nodeName != "" && pod.NodeName() != r.nodeName {
+		return
+	}
 	switch e {
 	case ADD:
 		rpt := report.MakeReport()