Help us shape the future of Go! Take the 2026 Go Developer Survey

dns

package
v1.14.3 Latest Latest
Warning

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

 Go to latest Published: Oct 9, 2026 License: GPL-2.0 Imports: 35 Imported by: 15

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrNoRawSupport           = E.New("no raw query support by current transport")
	ErrNotCached              = E.New("not cached")
	ErrResponseRejected       = E.New("response rejected")
	ErrResponseRejectedCached = E.Extend(ErrResponseRejected, "cached")
)

Functions

func FixedResponse 

func FixedResponse(id uint16, question dns.Question, addresses []netip.Addr, timeToLive uint32) *dns.Msg

func FixedResponseCNAME 

func FixedResponseCNAME(id uint16, question dns.Question, record string, timeToLive uint32) *dns.Msg

func FixedResponseMX 

func FixedResponseMX(id uint16, question dns.Question, records []*net.MX, timeToLive uint32) *dns.Msg

func FixedResponseStatus added in v1.12.0 

func FixedResponseStatus(message *dns.Msg, rcode int) *dns.Msg

func FixedResponseTXT 

func FixedResponseTXT(id uint16, question dns.Question, records []string, timeToLive uint32) *dns.Msg

func FormatQuestion 

func FormatQuestion(string string) string

func FqdnToDomain 

func FqdnToDomain(fqdn string) string

func MessageToAddresses 

func MessageToAddresses(response *dns.Msg) []netip.Addr

func NewLocalDialer 

func NewLocalDialer(ctx context.Context, options option.LocalDNSServerOptions) (N.Dialer, error)

func NewRemoteDialer 

func NewRemoteDialer(ctx context.Context, options option.RemoteDNSServerOptions) (N.Dialer, error)

func RegisterTransport 

func RegisterTransport[Options any](registry *TransportRegistry, transportType string, constructor TransportConstructorFunc[Options])

func SetClientSubnet 

func SetClientSubnet(message *dns.Msg, clientSubnet netip.Prefix) *dns.Msg

func TruncateDNSMessage 

func TruncateDNSMessage(request *dns.Msg, response *dns.Msg, frontHeadroom int, rearHeadroom int) (*buf.Buffer, error)

Types

type Client 

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

func NewClient 

func NewClient(options ClientOptions) *Client

func (*Client) ClearCache 

func (c *Client) ClearCache()

func (*Client) Exchange 

func (c *Client) Exchange(ctx context.Context, transport adapter.DNSTransport, message *dns.Msg, options adapter.DNSQueryOptions, responseChecker func(response *dns.Msg) bool) (*dns.Msg, error)

func (*Client) ExchangeAsync added in v1.14.0 

func (c *Client) ExchangeAsync(ctx context.Context, transport adapter.DNSTransport, message *dns.Msg, options adapter.DNSQueryOptions, responseChecker func(response *dns.Msg) bool, callback func(response *dns.Msg, err error))

func (*Client) Lookup 

func (c *Client) Lookup(ctx context.Context, transport adapter.DNSTransport, domain string, options adapter.DNSQueryOptions, responseChecker func(response *dns.Msg) bool) ([]netip.Addr, error)

func (*Client) Start 

func (c *Client) Start()

type ClientOptions 

type ClientOptions struct {
	Context           context.Context
	Timeout           time.Duration
	DisableCache      bool
	DisableExpire     bool
	OptimisticTimeout time.Duration
	CacheCapacity     uint32
	ClientSubnet      netip.Prefix
	RDRC              func() adapter.RDRCStore
	DNSCache          func() adapter.DNSCacheStore
	Logger            logger.ContextLogger
}

type RcodeError 

type RcodeError int
const (
	RcodeSuccess       RcodeError = mDNS.RcodeSuccess
	RcodeServerFailure RcodeError = mDNS.RcodeServerFailure
	RcodeFormatError   RcodeError = mDNS.RcodeFormatError
	RcodeNameError     RcodeError = mDNS.RcodeNameError
	RcodeRefused       RcodeError = mDNS.RcodeRefused
)

func (RcodeError) Error 

func (e RcodeError) Error() string

type Router 

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

func NewRouter 

func NewRouter(ctx context.Context, logFactory log.Factory, options option.DNSOptions) (*Router, error)

func (*Router) ClearCache 

func (r *Router) ClearCache()

func (*Router) Exchange 

func (r *Router) Exchange(ctx context.Context, message *mDNS.Msg, options adapter.DNSQueryOptions) (*mDNS.Msg, error)

func (*Router) ExchangeAsync added in v1.14.0 

func (r *Router) ExchangeAsync(ctx context.Context, message *mDNS.Msg, options adapter.DNSQueryOptions, callback func(response *mDNS.Msg, err error))

func (*Router) Initialize 

func (r *Router) Initialize(rules []option.DNSRule) error

func (*Router) Lookup 

func (r *Router) Lookup(ctx context.Context, domain string, options adapter.DNSQueryOptions) ([]netip.Addr, error)

func (*Router) LookupReverseMapping 

func (r *Router) LookupReverseMapping(ip netip.Addr) (string, bool)

func (*Router) ResetNetwork 

func (r *Router) ResetNetwork()

func (*Router) Start 

func (r *Router) Start(stage adapter.StartStage, scope *adapter.Scope) error

func (*Router) ValidateRuleSetMetadataUpdate added in v1.14.0 

func (r *Router) ValidateRuleSetMetadataUpdate(tag string, metadata adapter.RuleSetMetadata) error

type TransportAdapter 

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

func NewTransportAdapter 

func NewTransportAdapter(transportType string, transportTag string, dependencies []string) TransportAdapter

func NewTransportAdapterWithLocalOptions 

func NewTransportAdapterWithLocalOptions(transportType string, transportTag string, localOptions option.LocalDNSServerOptions) TransportAdapter

func NewTransportAdapterWithRemoteOptions 

func NewTransportAdapterWithRemoteOptions(transportType string, transportTag string, remoteOptions option.RemoteDNSServerOptions) TransportAdapter

func (*TransportAdapter) Dependencies 

func (a *TransportAdapter) Dependencies() []string

func (*TransportAdapter) References added in v1.14.3 

func (a *TransportAdapter) References() []string

func (*TransportAdapter) Tag 

func (a *TransportAdapter) Tag() string

func (*TransportAdapter) Type 

func (a *TransportAdapter) Type() string

type TransportConstructorFunc 

type TransportConstructorFunc[T any] func(ctx context.Context, logger log.ContextLogger, tag string, options T) (adapter.DNSTransport, error)

type TransportManager 

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

func NewTransportManager 

func NewTransportManager(registry adapter.DNSTransportRegistry, outbound adapter.OutboundManager, defaultTag string) *TransportManager

func (*TransportManager) Create 

func (m *TransportManager) Create(ctx context.Context, logger log.ContextLogger, tag string, transportType string, options any) error

func (*TransportManager) Default 

func (m *TransportManager) Default() adapter.DNSTransport

func (*TransportManager) FakeIP 

func (m *TransportManager) FakeIP() adapter.FakeIPTransport

func (*TransportManager) Initialize 

func (m *TransportManager) Initialize(defaultTransportFallback func() (adapter.DNSTransport, error))

func (*TransportManager) Start 

func (m *TransportManager) Start(stage adapter.StartStage, scope *adapter.Scope) error

func (*TransportManager) Transport 

func (m *TransportManager) Transport(tag string) (adapter.DNSTransport, bool)

func (*TransportManager) Transports 

func (m *TransportManager) Transports() []adapter.DNSTransport

type TransportRegistry 

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

func NewTransportRegistry 

func NewTransportRegistry() *TransportRegistry

func (*TransportRegistry) CreateDNSTransport 

func (r *TransportRegistry) CreateDNSTransport(ctx context.Context, logger log.ContextLogger, tag string, transportType string, options any) (adapter.DNSTransport, error)

func (*TransportRegistry) CreateOptions 

func (r *TransportRegistry) CreateOptions(transportType string) (any, bool)

func (*TransportRegistry) OptionTypes added in v1.14.0 

func (r *TransportRegistry) OptionTypes() []string

Source Files

View all Source files

Directories

Path Synopsis
dhcp
fakeip
hosts
local
local/systemconfig
mdns
quic

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.