altered nodeName checking for Scope cluster role

This commit is contained in:
cimaol
2020-03-10 10:07:59 +00:00
parent 19fae5bc7d
commit c301d3e93c
+5 -6
View File
@@ -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)