resolver

package
v1.6.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 6, 2025 License: MIT Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DNSKEYFlagKSK    = 0x0001
	DNSKEYFlagRevoke = 0x0080
)

Variables

This section is empty.

Functions

func AcquireBuf added in v1.0.0 

func AcquireBuf(size uint16) []byte

AcquireBuf returns a buffer from the appropriate pool.

func AcquireMsg added in v1.0.0 

func AcquireMsg() *dns.Msg

AcquireMsg returns an empty msg from pool.

func ReleaseBuf added in v1.0.0 

func ReleaseBuf(buf []byte)

ReleaseBuf returns buf to the appropriate pool.

func ReleaseConn added in v1.0.0 

func ReleaseConn(co *Conn)

ReleaseConn returns req to pool.

func ReleaseMsg added in v1.0.0 

func ReleaseMsg(req *dns.Msg)

ReleaseMsg returns req to pool.

func SetEDNSKeepalive added in v1.5.0 

func SetEDNSKeepalive(msg *dns.Msg, timeout uint16)

SetEDNSKeepalive adds EDNS-Keepalive option to a message.

Types

type Conn added in v1.0.0 

type Conn struct {
	net.Conn        // a net.Conn holding the connection
	UDPSize  uint16 // minimum receive buffer for UDP messages
}

Conn A Conn represents a connection to a DNS server.

func AcquireConn added in v1.0.0 

func AcquireConn() *Conn

AcquireConn returns an empty conn from pool.

func (*Conn) Exchange added in v1.0.0 

func (co *Conn) Exchange(m *dns.Msg) (r *dns.Msg, rtt time.Duration, err error)

(*Conn).Exchange exchange performs a synchronous query.

func (*Conn) Read added in v1.0.0 

func (co *Conn) Read(p []byte) (n int, err error)

(*Conn).Read read implements the net.Conn read method.

func (*Conn) ReadMsg added in v1.0.0 

func (co *Conn) ReadMsg() (*dns.Msg, error)

(*Conn).ReadMsg readMsg reads a message from the connection co. If the received message contains a TSIG record the transaction signature is verified. This method always tries to return the message, however if an error is returned there are no guarantees that the returned message is a valid representation of the packet read.

func (*Conn) Write added in v1.0.0 

func (co *Conn) Write(p []byte) (int, error)

(*Conn).Write write implements the net.Conn Write method.

func (*Conn) WriteMsg added in v1.0.0 

func (co *Conn) WriteMsg(m *dns.Msg) (err error)

(*Conn).WriteMsg writeMsg sends a message through the connection co. If the message m contains a TSIG record the transaction signature is calculated.

type DNSHandler 

type DNSHandler struct {
	// contains filtered or unexported fields
}

DNSHandler type.

func New 

func New(cfg *config.Config) *DNSHandler

New returns a new Handler.

func (*DNSHandler) Name 

func (h *DNSHandler) Name() string

(*DNSHandler).Name name return middleware name.

func (*DNSHandler) ServeDNS 

func (h *DNSHandler) ServeDNS(ctx context.Context, ch *middleware.Chain)

(*DNSHandler).ServeDNS serveDNS implements the Handle interface.

func (*DNSHandler) Stop added in v1.5.0 

func (h *DNSHandler) Stop()

(*DNSHandler).Stop stop gracefully shuts down the resolver.

type Resolver 

type Resolver struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Resolver type.

func NewResolver 

func NewResolver(cfg *config.Config) *Resolver

NewResolver return a resolver.

func (*Resolver) AutoTA added in v1.3.3 

func (r *Resolver) AutoTA()

func (*Resolver) Resolve 

func (r *Resolver) Resolve(ctx context.Context, req *dns.Msg, servers *authcache.AuthServers, root bool, depth int, level int, nomin bool, parentdsrr []dns.RR, extra ...bool) (*dns.Msg, error)

(*Resolver).Resolve resolve starts a DNS resolution - public interface with old signature for compatibility.

type SingleflightWrapper added in v1.5.1 

type SingleflightWrapper struct {
	// contains filtered or unexported fields
}

SingleflightWrapper wraps singleflight.Group with timeout tracking.

func NewSingleflightWrapper added in v1.5.1 

func NewSingleflightWrapper() *SingleflightWrapper

NewSingleflightWrapper creates a new wrapper with periodic cleanup.

func (*SingleflightWrapper) DoChan added in v1.5.1 

func (w *SingleflightWrapper) DoChan(key string, fn func() (any, error)) <-chan singleflight.Result

(*SingleflightWrapper).DoChan doChan wraps singleflight.DoChan with timeout tracking.

func (*SingleflightWrapper) Forget added in v1.5.1 

func (w *SingleflightWrapper) Forget(key string)

(*SingleflightWrapper).Forget forget wraps singleflight.Forget and cleans up tracking.

func (*SingleflightWrapper) TimedDoChan added in v1.5.1 

func (w *SingleflightWrapper) TimedDoChan(ctx context.Context, key string, fn func() (any, error)) (any, error)

(*SingleflightWrapper).TimedDoChan timedDoChan executes a function with built-in timeout handling.

type State added in v1.3.3 

type State int

State represents the state of a trust anchor in RFC 5011 lifecycle. 

const (
	StateStart State = iota
	StateAddPend
	StateValid
	StateMissing
	StateRevoked
	StateRemoved
)

func (State) String added in v1.3.3 

func (s State) String() string

type TCPConnPool added in v1.5.0 

type TCPConnPool struct {
	// contains filtered or unexported fields
}

TCPConnPool manages persistent TCP connections to DNS servers.

func NewTCPConnPool added in v1.5.0 

func NewTCPConnPool(rootTimeout, tldTimeout time.Duration, maxConns int) *TCPConnPool

NewTCPConnPool creates a new TCP connection pool.

func (*TCPConnPool) Close added in v1.5.0 

func (p *TCPConnPool) Close()

(*TCPConnPool).Close close closes all connections in the pool.

func (*TCPConnPool) Get added in v1.5.0 

func (p *TCPConnPool) Get(server string, isRoot, isTLD bool) *dns.Conn

(*TCPConnPool).Get get retrieves a connection for the given server.

func (*TCPConnPool) Put added in v1.5.0 

func (p *TCPConnPool) Put(conn *dns.Conn, server string, isRoot, isTLD bool, msg *dns.Msg)

(*TCPConnPool).Put put returns a connection to the pool.

func (*TCPConnPool) Stats added in v1.5.0 

func (p *TCPConnPool) Stats() (hits, misses int64, active int)

(*TCPConnPool).Stats stats returns pool statistics.

type TrustAnchor added in v1.3.3 

type TrustAnchor struct {
	DNSKey    *dns.DNSKEY
	State     State
	FirstSeen time.Time
}

TrustAnchor holds a DNSSEC trust anchor with its state and metadata.

type TrustAnchors added in v1.3.3 

type TrustAnchors map[uint16]*TrustAnchor

TrustAnchors maps key tags to their trust anchor data.

type ValidationError added in v1.5.1 

type ValidationError struct {
	Code    uint16
	Message string
	Err     error
}

ValidationError represents a DNS validation error with EDE information.

func DNSKEYMissingForZone added in v1.5.1 

func DNSKEYMissingForZone(zone string) *ValidationError

DNSKEYMissingForZone common error creation helpers.

func NewNetworkError added in v1.5.1 

func NewNetworkError(err error) *ValidationError

NewNetworkError creates a network error with EDE information.

func NewNoReachableAuthorityError added in v1.5.1 

func NewNoReachableAuthorityError(message string) *ValidationError

NewNoReachableAuthorityError creates an error for unreachable servers.

func NoReachableAuthAtZone added in v1.5.1 

func NoReachableAuthAtZone(zone string) *ValidationError

NoReachableAuthAtZone creates an error with zone context.

func SignatureExpiredForRRset added in v1.5.1 

func SignatureExpiredForRRset(rrtype string, zone string) *ValidationError

func (*ValidationError) EDECode added in v1.5.1 

func (e *ValidationError) EDECode() uint16

(*ValidationError).EDECode EDECode returns the EDE code for this error.

func (*ValidationError) Error added in v1.5.1 

func (e *ValidationError) Error() string

func (*ValidationError) Unwrap added in v1.5.1 

func (e *ValidationError) Unwrap() error

func (*ValidationError) WithContext added in v1.5.1 

func (e *ValidationError) WithContext(format string, args ...any) *ValidationError

(*ValidationError).WithContext withContext creates a new ValidationError with additional context.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.