resolver

package
v1.5.3 Latest Latest
Warning

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

 Go to latest Published: Jun 8, 2025 License: MIT Imports: 26 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
}

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)

Exchange performs a synchronous query

func (*Conn) Read added in v1.0.0 

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

Read implements the net.Conn read method.

func (*Conn) ReadMsg added in v1.0.0 

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

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)

Write implements the net.Conn Write method.

func (*Conn) WriteMsg added in v1.0.0 

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

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

Name return middleware name

func (*DNSHandler) ServeDNS 

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

ServeDNS implements the Handle interface.

func (*DNSHandler) Stop added in v1.5.0 

func (h *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)

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

DoChan wraps singleflight.DoChan with timeout tracking

func (*SingleflightWrapper) Forget added in v1.5.1 

func (w *SingleflightWrapper) Forget(key string)

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)

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()

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

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)

Put returns a connection to the pool

func (*TCPConnPool) Stats added in v1.5.0 

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

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

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

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

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.