diff options
| author |  Chris O'Haver <cohaver@infoblox.com>
| 2022-03-25 13:50:23 -0400 |
|---|---|---|
| committer |  GitHub <noreply@github.com>
| 2022-03-25 13:50:23 -0400 |
| commit | 3df3147f8c6437064da64fab096bd4a4ec8ab61b (patch) | |
| tree | 2252f77f686fdfbd7ff32c1fa16eb4ab786801e9 /plugin/k8s_external/msg_to_dns.go | |
| parent | 27e18e72bc454026cf0ed8b82d87a9b6425a9f3e (diff) | |
| download | coredns-3df3147f8c6437064da64fab096bd4a4ec8ab61b.tar.gz coredns-3df3147f8c6437064da64fab096bd4a4ec8ab61b.tar.zst coredns-3df3147f8c6437064da64fab096bd4a4ec8ab61b.zip | |
plugin/k8s_external: Persist tc bit from lookup to client response (#4716)
* persist reponse tc bit from lookup to client
Signed-off-by: Chris O'Haver <cohaver@infoblox.com>
Diffstat (limited to 'plugin/k8s_external/msg_to_dns.go')
| -rw-r--r-- | plugin/k8s_external/msg_to_dns.go | 14 |
1 files changed, 10 insertions, 4 deletions
diff --git a/plugin/k8s_external/msg_to_dns.go b/plugin/k8s_external/msg_to_dns.go index 8920f4a00..540c8f442 100644 --- a/plugin/k8s_external/msg_to_dns.go +++ b/plugin/k8s_external/msg_to_dns.go @@ -10,7 +10,7 @@ import ( "github.com/miekg/dns" ) -func (e *External) a(ctx context.Context, services []msg.Service, state request.Request) (records []dns.RR) { +func (e *External) a(ctx context.Context, services []msg.Service, state request.Request) (records []dns.RR, truncated bool) { dup := make(map[string]struct{}) for _, s := range services { @@ -23,6 +23,9 @@ func (e *External) a(ctx context.Context, services []msg.Service, state request. records = append(records, rr) if resp, err := e.upstream.Lookup(ctx, state, dns.Fqdn(s.Host), dns.TypeA); err == nil { records = append(records, resp.Answer...) + if resp.Truncated { + truncated = true + } } case dns.TypeA: @@ -37,10 +40,10 @@ func (e *External) a(ctx context.Context, services []msg.Service, state request. // nada } } - return records + return records, truncated } -func (e *External) aaaa(ctx context.Context, services []msg.Service, state request.Request) (records []dns.RR) { +func (e *External) aaaa(ctx context.Context, services []msg.Service, state request.Request) (records []dns.RR, truncated bool) { dup := make(map[string]struct{}) for _, s := range services { @@ -53,6 +56,9 @@ func (e *External) aaaa(ctx context.Context, services []msg.Service, state reque records = append(records, rr) if resp, err := e.upstream.Lookup(ctx, state, dns.Fqdn(s.Host), dns.TypeAAAA); err == nil { records = append(records, resp.Answer...) + if resp.Truncated { + truncated = true + } } case dns.TypeA: @@ -67,7 +73,7 @@ func (e *External) aaaa(ctx context.Context, services []msg.Service, state reque } } } - return records + return records, truncated } func (e *External) srv(ctx context.Context, services []msg.Service, state request.Request) (records, extra []dns.RR) { |