diff options
author | 2017-11-15 15:04:17 +0000 | |
---|---|---|
committer | 2017-11-15 15:04:17 +0000 | |
commit | 70a5a098c1c5058fce5b16ae22d0bb008c51e05c (patch) | |
tree | 94e0637e04c1a3a8892e00515d7c65a16d10446b /plugin/kubernetes/reverse.go | |
parent | 621dd36f6d67a1be4549f6d70aa6e787326e274b (diff) | |
download | coredns-70a5a098c1c5058fce5b16ae22d0bb008c51e05c.tar.gz coredns-70a5a098c1c5058fce5b16ae22d0bb008c51e05c.tar.zst coredns-70a5a098c1c5058fce5b16ae22d0bb008c51e05c.zip |
plugin/kubernetes: Fix reverse TTL response (#1240)
Remove most 303 TTLs (those get skipped by the test) and use 5, which is
the default for all tests.
Diffstat (limited to 'plugin/kubernetes/reverse.go')
-rw-r--r-- | plugin/kubernetes/reverse.go | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/plugin/kubernetes/reverse.go b/plugin/kubernetes/reverse.go index e74ab88f1..66e2fc128 100644 --- a/plugin/kubernetes/reverse.go +++ b/plugin/kubernetes/reverse.go @@ -26,22 +26,22 @@ func (k *Kubernetes) Reverse(state request.Request, exact bool, opt plugin.Optio func (k *Kubernetes) serviceRecordForIP(ip, name string) []msg.Service { // First check services with cluster ips for _, service := range k.APIConn.SvcIndexReverse(ip) { - if (len(k.Namespaces) > 0) && !k.namespaceExposed(service.Namespace) { + if len(k.Namespaces) > 0 && !k.namespaceExposed(service.Namespace) { continue } domain := strings.Join([]string{service.Name, service.Namespace, Svc, k.primaryZone()}, ".") - return []msg.Service{{Host: domain}} + return []msg.Service{{Host: domain, TTL: k.ttl}} } // If no cluster ips match, search endpoints for _, ep := range k.APIConn.EpIndexReverse(ip) { - if (len(k.Namespaces) > 0) && !k.namespaceExposed(ep.ObjectMeta.Namespace) { + if len(k.Namespaces) > 0 && !k.namespaceExposed(ep.ObjectMeta.Namespace) { continue } for _, eps := range ep.Subsets { for _, addr := range eps.Addresses { if addr.IP == ip { domain := strings.Join([]string{endpointHostname(addr, k.endpointNameMode), ep.ObjectMeta.Name, ep.ObjectMeta.Namespace, Svc, k.primaryZone()}, ".") - return []msg.Service{{Host: domain}} + return []msg.Service{{Host: domain, TTL: k.ttl}} } } } |