From b7359e1d45f505171356bcae3c7d5e2341ecc859 Mon Sep 17 00:00:00 2001 From: radhitya Date: Sun, 21 Jun 2026 09:48:42 +0700 Subject: forward mode, cache opt, ACL, rate limit, admin/health, systemd, fix UDP reply --- internal/resolver/resolver.go | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) (limited to 'internal/resolver/resolver.go') diff --git a/internal/resolver/resolver.go b/internal/resolver/resolver.go index 1e4f1da..c7a0694 100644 --- a/internal/resolver/resolver.go +++ b/internal/resolver/resolver.go @@ -20,8 +20,8 @@ type Resolver struct { maxDelegations int timeout time.Duration retries int - forwarders []string - client *dns.Client + forwarders []string + client *dns.Client } type Option func(*Resolver) @@ -77,7 +77,7 @@ func (r *Resolver) forward(ctx context.Context, qname string, qtype uint16) (*dn reply, err := r.exchangeWithRetries(ctx, servers, qname, qtype, true) if err != nil { return nil, fmt.Errorf("forward %s %s: %w", - qname, dns.TypeToString[qtype],err) + qname, dns.TypeToString[qtype], err) } return reply, nil } @@ -94,10 +94,10 @@ func (r *Resolver) resolve(ctx context.Context, qname string, qtype uint16) (*dn return nil, ErrNoServers } reply, err := r.exchangeWithRetries(ctx, servers, qname, qtype, - false) + false) if err != nil { return nil, fmt.Errorf("resolve %s %s: %w", - qname, dns.TypeToString[qtype], err) + qname, dns.TypeToString[qtype], err) } switch { case reply.Rcode == dns.RcodeSuccess && len(reply.Answer) > 0: @@ -248,7 +248,7 @@ func (r *Resolver) nextServers(ctx context.Context, msg *dns.Msg) ([]string, err } func (r *Resolver) exchangeWithRetries(ctx context.Context, servers []string, -qname string, qtype uint16, rd bool) (*dns.Msg, error) { + qname string, qtype uint16, rd bool) (*dns.Msg, error) { msg := dns.NewMsg(qname, qtype) msg.UDPSize = 4096 @@ -256,7 +256,7 @@ qname string, qtype uint16, rd bool) (*dns.Msg, error) { type result struct { reply *dns.Msg - err error + err error } ch := make(chan result, len(servers)) -- cgit v1.2.3