aboutsummaryrefslogtreecommitdiff
path: root/plugin/kubernetes/local.go
diff options
context:
space:
mode:
authorGravatar Chris O'Haver <cohaver@infoblox.com> 2018-10-10 15:28:45 -0400
committerGravatar John Belamaric <jbelamaric@google.com> 2018-10-10 12:28:45 -0700
commit974ed086f25ad45a01947e276e2eb8aa73d007a3 (patch)
tree2c1468f5a4e90634382a81904ef2736ca44198a7 /plugin/kubernetes/local.go
parent8432f1420732e61cb1a7ebb9d6446db6f43aa850 (diff)
downloadcoredns-974ed086f25ad45a01947e276e2eb8aa73d007a3.tar.gz
coredns-974ed086f25ad45a01947e276e2eb8aa73d007a3.tar.zst
coredns-974ed086f25ad45a01947e276e2eb8aa73d007a3.zip
use keys (#2167)
Diffstat (limited to 'plugin/kubernetes/local.go')
-rw-r--r--plugin/kubernetes/local.go16
1 files changed, 10 insertions, 6 deletions
diff --git a/plugin/kubernetes/local.go b/plugin/kubernetes/local.go
index e15fec497..7a85de1bf 100644
--- a/plugin/kubernetes/local.go
+++ b/plugin/kubernetes/local.go
@@ -28,14 +28,18 @@ func (k *Kubernetes) localNodeName() string {
}
// Find endpoint matching localIP
- for _, ep := range k.APIConn.EpIndexReverse(localIP.String()) {
- for _, eps := range ep.Subsets {
- for _, addr := range eps.Addresses {
- if localIP.Equal(net.ParseIP(addr.IP)) {
- return addr.NodeName
- }
+ ep := k.APIConn.EpIndexReverse(localIP.String())
+ if ep == nil {
+ return ""
+ }
+
+ for _, eps := range ep.Subsets {
+ for _, addr := range eps.Addresses {
+ if localIP.Equal(net.ParseIP(addr.IP)) {
+ return addr.NodeName
}
}
}
+
return ""
}