From c301d3e93c9d05a7e246759a3a6db7cdc350939d Mon Sep 17 00:00:00 2001 From: cimaol Date: Tue, 10 Mar 2020 10:07:59 +0000 Subject: [PATCH] altered nodeName checking for Scope cluster role --- probe/kubernetes/reporter.go | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/probe/kubernetes/reporter.go b/probe/kubernetes/reporter.go index 98468720c..3b6400e06 100644 --- a/probe/kubernetes/reporter.go +++ b/probe/kubernetes/reporter.go @@ -1,7 +1,6 @@ package kubernetes import ( - "fmt" "k8s.io/apimachinery/pkg/labels" "github.com/weaveworks/common/mtime" @@ -654,13 +653,13 @@ func (r *Reporter) podTopology(services []Service, deployments []Deployment, dae )) } } - // filter out non-local pods: we only want to report local ones for performance reasons. - if r.nodeName == "" { - return pods, fmt.Errorf("pod topology failure: no node name given for reporter") - } + err := r.client.WalkPods(func(p Pod) error { - if p.NodeName() != r.nodeName { + // filter out non-local pods: we only want to report local ones for performance reasons. + if r.nodeName != "" { + if p.NodeName() != r.nodeName { return nil + } } for _, selector := range selectors { selector(p)