aboutsummaryrefslogtreecommitdiff
path: root/plugin/kubernetes/kubernetes.go
diff options
context:
space:
mode:
authorGravatar Miek Gieben <miek@miek.nl> 2018-10-11 21:59:50 +0100
committerGravatar Chris O'Haver <cohaver@infoblox.com> 2018-10-11 16:59:50 -0400
commit6ed88fab744bd3d8cc071153a4c78970798cf9e6 (patch)
treeab4935e8cb81931b65966ba13829f3f8780b12b3 /plugin/kubernetes/kubernetes.go
parentc8fb66f8cc60ff17b916b033982c5491f23cdcc9 (diff)
downloadcoredns-6ed88fab744bd3d8cc071153a4c78970798cf9e6.tar.gz
coredns-6ed88fab744bd3d8cc071153a4c78970798cf9e6.tar.zst
coredns-6ed88fab744bd3d8cc071153a4c78970798cf9e6.zip
Revert "use keys (#2167)" (#2188)
This reverts commit 974ed086f25ad45a01947e276e2eb8aa73d007a3.
Diffstat (limited to 'plugin/kubernetes/kubernetes.go')
-rw-r--r--plugin/kubernetes/kubernetes.go9
1 files changed, 3 insertions, 6 deletions
diff --git a/plugin/kubernetes/kubernetes.go b/plugin/kubernetes/kubernetes.go
index 8ba21a70e..81cf19492 100644
--- a/plugin/kubernetes/kubernetes.go
+++ b/plugin/kubernetes/kubernetes.go
@@ -444,12 +444,9 @@ func (k *Kubernetes) findServices(r recordRequest, zone string) (services []msg.
serviceList = k.APIConn.ServiceList()
endpointsListFunc = func() []*object.Endpoints { return k.APIConn.EndpointsList() }
} else {
- key := object.ServiceKey(r.namespace, r.service)
- s := k.APIConn.SvcIndex(key)
- if s != nil {
- serviceList = append(serviceList, s)
- }
- endpointsListFunc = func() []*object.Endpoints { return []*object.Endpoints{k.APIConn.EpIndex(key)} }
+ idx := object.ServiceKey(r.service, r.namespace)
+ serviceList = k.APIConn.SvcIndex(idx)
+ endpointsListFunc = func() []*object.Endpoints { return k.APIConn.EpIndex(idx) }
}
for _, svc := range serviceList {