diff options
Diffstat (limited to 'plugin/kubernetes/ns.go')
| -rw-r--r-- | plugin/kubernetes/ns.go | 10 |
1 files changed, 3 insertions, 7 deletions
diff --git a/plugin/kubernetes/ns.go b/plugin/kubernetes/ns.go index 4cacc382f..c4b05d5b5 100644 --- a/plugin/kubernetes/ns.go +++ b/plugin/kubernetes/ns.go @@ -5,7 +5,7 @@ import ( "strings" "github.com/miekg/dns" - "k8s.io/client-go/1.5/pkg/api" + api "k8s.io/client-go/pkg/api/v1" ) func isDefaultNS(name, zone string) bool { @@ -20,12 +20,10 @@ func (k *Kubernetes) nsAddr() *dns.A { rr := new(dns.A) localIP := k.interfaceAddrsFunc() - endpointsList := k.APIConn.EndpointsList() - rr.A = localIP FindEndpoint: - for _, ep := range endpointsList.Items { + for _, ep := range k.APIConn.EndpointsList() { for _, eps := range ep.Subsets { for _, addr := range eps.Addresses { if localIP.Equal(net.ParseIP(addr.IP)) { @@ -42,11 +40,9 @@ FindEndpoint: rr.A = localIP return rr } - // Find service to get ClusterIP - serviceList := k.APIConn.ServiceList() FindService: - for _, svc := range serviceList { + for _, svc := range k.APIConn.ServiceList() { if svcName == svc.Name && svcNamespace == svc.Namespace { if svc.Spec.ClusterIP == api.ClusterIPNone { rr.A = localIP |