dns

package
v1.16.4 Latest Latest
Warning

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

 Go to latest Published: Nov 2, 2023 License: GPL-3.0 Imports: 47 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	IfaceTTL    = time.Second * 20
	DHCPTTL     = time.Hour
	DHCPTimeout = time.Minute
)
View Source 
const (
	// QUICCodeNoError is used when the connection or stream needs to be closed,
	// but there is no error to signal.
	QUICCodeNoError = quic.ApplicationErrorCode(0)
	// QUICCodeInternalError signals that the DoQ implementation encountered
	// an internal error and is incapable of pursuing the transaction or the
	// connection.
	QUICCodeInternalError = quic.ApplicationErrorCode(1)
	// QUICKeepAlivePeriod is the value that we pass to *quic.Config and that
	// controls the period with with keep-alive frames are being sent to the
	// connection. We set it to 20s as it would be in the quic-go@v0.27.1 with
	// KeepAlive field set to true This value is specified in
	// https://pkg.go.dev/github.com/metacubex/quic-go/internal/protocol#MaxKeepAliveInterval.
	//
	// TODO(ameshkov):  Consider making it configurable.
	QUICKeepAlivePeriod = time.Second * 20
	DefaultTimeout      = time.Second * 5
)
View Source 
const (
	MaxMsgSize = 65535
)
View Source 
const NextProtoDQ = "doq"

Variables

View Source 
var DefaultHTTPVersions = []C.HTTPVersion{C.HTTPVersion11, C.HTTPVersion2}
View Source 
var ParseNameServer func(servers []string) ([]NameServer, error) // define in config/config.go

Functions

func AddPrefix 

func AddPrefix(b []byte) (m []byte)

AddPrefix adds a 2-byte prefix with the DNS message length.

func NewDomainFilter 

func NewDomainFilter(domains []string) *domainFilter

func NewGeoSite 

func NewGeoSite(group string) (fallbackDomainFilter, error)

func NewHandler 

func NewHandler(resolver *Resolver, mapper *ResolverEnhancer) handler

func ReCreateServer 

func ReCreateServer(addr string, resolver *Resolver, mapper *ResolverEnhancer)

Types

type Config 

type Config struct {
	Main, Fallback  []NameServer
	Default         []NameServer
	ProxyServer     []NameServer
	IPv6            bool
	IPv6Timeout     uint
	EnhancedMode    C.DNSMode
	FallbackFilter  FallbackFilter
	Pool            *fakeip.Pool
	Hosts           *trie.DomainTrie[resolver.HostValue]
	Policy          map[string][]NameServer
	DomainSetPolicy map[provider.RuleProvider][]NameServer
	GeositePolicy   map[router.DomainMatcher][]NameServer
}

type FallbackFilter 

type FallbackFilter struct {
	GeoIP     bool
	GeoIPCode string
	IPCIDR    []*netip.Prefix
	Domain    []string
	GeoSite   []*router.DomainMatcher
}

type LocalServer 

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

func NewLocalServer 

func NewLocalServer(resolver *Resolver, mapper *ResolverEnhancer) *LocalServer

func (*LocalServer) ServeMsg 

func (s *LocalServer) ServeMsg(ctx context.Context, msg *D.Msg) (*D.Msg, error)

ServeMsg implement resolver.LocalServer ResolveMsg

type NameServer 

type NameServer struct {
	Net          string
	Addr         string
	Interface    atomic.TypedValue[string]
	ProxyAdapter C.ProxyAdapter
	ProxyName    string
	Params       map[string]string
	PreferH3     bool
}

type Policy 

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

func NewPolicy 

func NewPolicy(data []dnsClient) *Policy

func (*Policy) Compare 

func (p *Policy) Compare(p2 *Policy) int

func (*Policy) GetData 

func (p *Policy) GetData() []dnsClient

type Resolver 

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

func NewProxyServerHostResolver 

func NewProxyServerHostResolver(old *Resolver) *Resolver

func NewResolver 

func NewResolver(config Config) *Resolver

func (*Resolver) Exchange 

func (r *Resolver) Exchange(m *D.Msg) (msg *D.Msg, err error)

Exchange a batch of dns request, and it use cache

func (*Resolver) ExchangeContext 

func (r *Resolver) ExchangeContext(ctx context.Context, m *D.Msg) (msg *D.Msg, err error)

ExchangeContext a batch of dns request with context.Context, and it use cache

func (*Resolver) Invalid 

func (r *Resolver) Invalid() bool

Invalid return this resolver can or can't be used

func (*Resolver) LookupIP 

func (r *Resolver) LookupIP(ctx context.Context, host string) (ips []netip.Addr, err error)

func (*Resolver) LookupIPPrimaryIPv4 

func (r *Resolver) LookupIPPrimaryIPv4(ctx context.Context, host string) (ips []netip.Addr, err error)

func (*Resolver) LookupIPv4 

func (r *Resolver) LookupIPv4(ctx context.Context, host string) ([]netip.Addr, error)

LookupIPv4 request with TypeA

func (*Resolver) LookupIPv6 

func (r *Resolver) LookupIPv6(ctx context.Context, host string) ([]netip.Addr, error)

LookupIPv6 request with TypeAAAA

type ResolverEnhancer 

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

func NewEnhancer 

func NewEnhancer(cfg Config) *ResolverEnhancer

func (*ResolverEnhancer) FakeIPEnabled 

func (h *ResolverEnhancer) FakeIPEnabled() bool

func (*ResolverEnhancer) FindHostByIP 

func (h *ResolverEnhancer) FindHostByIP(ip netip.Addr) (string, bool)

func (*ResolverEnhancer) FlushFakeIP 

func (h *ResolverEnhancer) FlushFakeIP() error

func (*ResolverEnhancer) InsertHostByIP 

func (h *ResolverEnhancer) InsertHostByIP(ip netip.Addr, host string)

func (*ResolverEnhancer) IsExistFakeIP 

func (h *ResolverEnhancer) IsExistFakeIP(ip netip.Addr) bool

func (*ResolverEnhancer) IsFakeBroadcastIP 

func (h *ResolverEnhancer) IsFakeBroadcastIP(ip netip.Addr) bool

func (*ResolverEnhancer) IsFakeIP 

func (h *ResolverEnhancer) IsFakeIP(ip netip.Addr) bool

func (*ResolverEnhancer) MappingEnabled 

func (h *ResolverEnhancer) MappingEnabled() bool

func (*ResolverEnhancer) PatchFrom 

func (h *ResolverEnhancer) PatchFrom(o *ResolverEnhancer)

func (*ResolverEnhancer) StoreFakePoolState 

func (h *ResolverEnhancer) StoreFakePoolState()

type Server 

type Server struct {
	*D.Server
	// contains filtered or unexported fields
}

func (*Server) ServeDNS 

func (s *Server) ServeDNS(w D.ResponseWriter, r *D.Msg)

ServeDNS implement D.Handler ServeDNS

func (*Server) SetHandler 

func (s *Server) SetHandler(handler handler)

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.