mirror of
https://github.com/coredns/coredns.git
synced 2025-11-01 18:53:43 -04:00
9026a4a295
* upstream lookups are done with original EDNS options Signed-off-by: Ondřej Benkovský <ondrej.benkovsky@jamf.com> * fixup! upstream lookups are done with original EDNS options Signed-off-by: Ondřej Benkovský <ondrej.benkovsky@jamf.com>
34 lines
971 B
Go
34 lines
971 B
Go
// Package upstream abstracts a upstream lookups so that plugins can handle them in an unified way.
|
|
package upstream
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
|
|
"github.com/coredns/coredns/core/dnsserver"
|
|
"github.com/coredns/coredns/plugin/pkg/nonwriter"
|
|
"github.com/coredns/coredns/request"
|
|
|
|
"github.com/miekg/dns"
|
|
)
|
|
|
|
// Upstream is used to resolve CNAME or other external targets via CoreDNS itself.
|
|
type Upstream struct{}
|
|
|
|
// New creates a new Upstream to resolve names using the coredns process.
|
|
func New() *Upstream { return &Upstream{} }
|
|
|
|
// Lookup routes lookups to our selves or forward to a remote.
|
|
func (u *Upstream) Lookup(ctx context.Context, state request.Request, name string, typ uint16) (*dns.Msg, error) {
|
|
server, ok := ctx.Value(dnsserver.Key{}).(*dnsserver.Server)
|
|
if !ok {
|
|
return nil, fmt.Errorf("no full server is running")
|
|
}
|
|
req := state.NewWithQuestion(name, typ)
|
|
|
|
nw := nonwriter.New(state.W)
|
|
server.ServeDNS(ctx, nw, req.Req)
|
|
|
|
return nw.Msg, nil
|
|
}
|