aboutsummaryrefslogtreecommitdiff
path: root/plugin/kubernetes/reverse.go
diff options
context:
space:
mode:
authorGravatar Chris O'Haver <cohaver@infoblox.com> 2020-02-21 01:24:02 -0500
committerGravatar GitHub <noreply@github.com> 2020-02-21 07:24:02 +0100
commit6ef105ced326f08212ed2f8cf2816a620e9a266a (patch)
tree9a5e6126f50b7657322c4e22205fdcb4c89d9d63 /plugin/kubernetes/reverse.go
parented1841c36f8633d7bd6ea3bc8a22eb16ce67377e (diff)
downloadcoredns-6ef105ced326f08212ed2f8cf2816a620e9a266a.tar.gz
coredns-6ef105ced326f08212ed2f8cf2816a620e9a266a.tar.zst
coredns-6ef105ced326f08212ed2f8cf2816a620e9a266a.zip
return all records with matching ip (#3687)
Signed-off-by: Chris O'Haver <cohaver@infoblox.com>
Diffstat (limited to 'plugin/kubernetes/reverse.go')
-rw-r--r--plugin/kubernetes/reverse.go5
1 files changed, 3 insertions, 2 deletions
diff --git a/plugin/kubernetes/reverse.go b/plugin/kubernetes/reverse.go
index 12b67ff30..b80a91fc2 100644
--- a/plugin/kubernetes/reverse.go
+++ b/plugin/kubernetes/reverse.go
@@ -38,6 +38,7 @@ func (k *Kubernetes) serviceRecordForIP(ip, name string) []msg.Service {
return []msg.Service{{Host: domain, TTL: k.ttl}}
}
// If no cluster ips match, search endpoints
+ var svcs []msg.Service
for _, ep := range k.APIConn.EpIndexReverse(ip) {
if len(k.Namespaces) > 0 && !k.namespaceExposed(ep.Namespace) {
continue
@@ -46,10 +47,10 @@ func (k *Kubernetes) serviceRecordForIP(ip, name string) []msg.Service {
for _, addr := range eps.Addresses {
if addr.IP == ip {
domain := strings.Join([]string{endpointHostname(addr, k.endpointNameMode), ep.Name, ep.Namespace, Svc, k.primaryZone()}, ".")
- return []msg.Service{{Host: domain, TTL: k.ttl}}
+ svcs = append(svcs, msg.Service{Host: domain, TTL: k.ttl})
}
}
}
}
- return nil
+ return svcs
}