diff options
author | 2020-02-21 01:24:02 -0500 | |
---|---|---|
committer | 2020-02-21 07:24:02 +0100 | |
commit | 6ef105ced326f08212ed2f8cf2816a620e9a266a (patch) | |
tree | 9a5e6126f50b7657322c4e22205fdcb4c89d9d63 /plugin/kubernetes/reverse.go | |
parent | ed1841c36f8633d7bd6ea3bc8a22eb16ce67377e (diff) | |
download | coredns-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.go | 5 |
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 } |