diff options
author | 2018-10-10 15:28:45 -0400 | |
---|---|---|
committer | 2018-10-10 12:28:45 -0700 | |
commit | 974ed086f25ad45a01947e276e2eb8aa73d007a3 (patch) | |
tree | 2c1468f5a4e90634382a81904ef2736ca44198a7 /plugin/kubernetes/local.go | |
parent | 8432f1420732e61cb1a7ebb9d6446db6f43aa850 (diff) | |
download | coredns-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.go | 16 |
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 "" } |