diff options
author | 2017-09-29 15:58:50 -0400 | |
---|---|---|
committer | 2017-09-29 15:58:50 -0400 | |
commit | 4b3a430ff2e6a39278eebd1493936c3a8a161fa0 (patch) | |
tree | a48c18346039c9b7808ec2395eeda49f8a0e1f0c /plugin/kubernetes/reverse.go | |
parent | 45b0252c1aa3c9afb1951d4185644e23805167e5 (diff) | |
download | coredns-4b3a430ff2e6a39278eebd1493936c3a8a161fa0.tar.gz coredns-4b3a430ff2e6a39278eebd1493936c3a8a161fa0.tar.zst coredns-4b3a430ff2e6a39278eebd1493936c3a8a161fa0.zip |
plugin/kubernetes: Enable protobuf, Update client api package (#1114)
* vendor
* code
Diffstat (limited to 'plugin/kubernetes/reverse.go')
-rw-r--r-- | plugin/kubernetes/reverse.go | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/plugin/kubernetes/reverse.go b/plugin/kubernetes/reverse.go index 0143b721a..84baae964 100644 --- a/plugin/kubernetes/reverse.go +++ b/plugin/kubernetes/reverse.go @@ -25,9 +25,7 @@ func (k *Kubernetes) Reverse(state request.Request, exact bool, opt plugin.Optio // If a service cluster ip does not match, it checks all endpoints func (k *Kubernetes) serviceRecordForIP(ip, name string) []msg.Service { // First check services with cluster ips - svcList := k.APIConn.ServiceList() - - for _, service := range svcList { + for _, service := range k.APIConn.ServiceList() { if (len(k.Namespaces) > 0) && !k.namespaceExposed(service.Namespace) { continue } @@ -37,8 +35,7 @@ func (k *Kubernetes) serviceRecordForIP(ip, name string) []msg.Service { } } // If no cluster ips match, search endpoints - epList := k.APIConn.EndpointsList() - for _, ep := range epList.Items { + for _, ep := range k.APIConn.EndpointsList() { if (len(k.Namespaces) > 0) && !k.namespaceExposed(ep.ObjectMeta.Namespace) { continue } |