dns

Documentation

Index

• Constants
• Variables
• func ArrayEquals(src, target []string) bool
• func Contains(container any, target any) bool
• func CreateDirIfNotExist(dir string) error
• func GetDnsRR(domain string)
• func GetLocalDomains() string
• func GetNameServer() string
• func GetRandomTcpPort() int
• func HandleExtraDomainMapping(extraDomains map[string]string, localDnsPort int)
• func IsDomainNotExist(err error) bool
• func IsValidIp(ip string) bool
• func NewDnsResolve(opts ...dnsResolveOpt) dnsResolve
• func NsLookup(domain string, qtype uint16, net, dnsServerAddr string) (*dns.Msg, error)
• func RandomPort() int
• func ReadCache(domain string, qtype uint16, ttl int64) []dns.RR
• func RestoreNameServer()
• func SetNameServer(dnsServer string, dnsMode string) error
• func SetupDnsServer(dnsHandler dns.Handler, port int, net string) error
• func SetupLocalDns(remoteDnsPort, localDnsPort int, dnsOrder []string, ttl int64) error
• func WithEscape(add, remove string) dnsResolveOpt
• func WithResolveConf(resolve string) dnsResolveOpt
• func WriteCache(domain string, qtype uint16, answer []dns.RR, timestamp int64)
• type DnsServer
  • func (s *DnsServer) ServeDNS(w dns.ResponseWriter, req *dns.Msg)
• type DomainNotExistError
  • func (e DomainNotExistError) Error() string
• type IDns
  • func NewDnsServer(a arecord, rtr rtrrecord, port int) IDns
• type NsEntry

Constants

const (
	StandardDnsPort    = 53
	AlternativeDnsPort = 10053
)

const IpAddrPattern = "[0-9]+\\.[0-9]+\\.[0-9]+\\.[0-9]+"

Variables

var (
	DnsResolve = NewDnsResolve(WithEscape(
		" # Added by NetTool", " # Removed by NetTool",
	))

	Iptables = iptables.NewIptablesRule()
)

var (
	// DnsOrderCluster proxy to cluster dns
	DnsOrderCluster = "cluster"
	// DnsOrderUpstream proxy to upstream dns
	DnsOrderUpstream = "upstream"
)

var (
	FieldNameserver = "nameserver"
	FieldDomain     = "domain"
	FieldSearch     = "search"
)

var (
	ResolvConf = "/etc/resolv.conf"
)

Functions

func ArrayEquals

func ArrayEquals(src, target []string) bool

func Contains

func Contains(container any, target any) bool

Contains check whether target exist in container, the type of container can be an array, slice or map

func CreateDirIfNotExist

func CreateDirIfNotExist(dir string) error

CreateDirIfNotExist create dir

func GetDnsRR

func GetDnsRR(domain string)

func GetLocalDomains

func GetLocalDomains() string

GetLocalDomains get domain search postfixes

func GetNameServer

func GetNameServer() string

GetNameServer get primary dns server

func GetRandomTcpPort

func GetRandomTcpPort() int

GetRandomTcpPort get pod random ssh port

func HandleExtraDomainMapping

func HandleExtraDomainMapping(extraDomains map[string]string, localDnsPort int)

HandleExtraDomainMapping handle extra domain change

func IsDomainNotExist

func IsDomainNotExist(err error) bool

IsDomainNotExist check the error type

func IsValidIp

func IsValidIp(ip string) bool

func NewDnsResolve

func NewDnsResolve(opts ...dnsResolveOpt) dnsResolve

func NsLookup

func NsLookup(domain string, qtype uint16, net, dnsServerAddr string) (*dns.Msg, error)

NsLookup query domain record, dnsServerAddr use '<ip>:<port>' format

func RandomPort

func RandomPort() int

func ReadCache

func ReadCache(domain string, qtype uint16, ttl int64) []dns.RR

ReadCache fetch from cache

func RestoreNameServer

func RestoreNameServer()

RestoreNameServer remove the nameservers added by ktctl

func SetNameServer

func SetNameServer(dnsServer string, dnsMode string) error

SetNameServer set dns server records

func SetupDnsServer

func SetupDnsServer(dnsHandler dns.Handler, port int, net string) error

SetupDnsServer start dns server on specified port

func SetupLocalDns

func SetupLocalDns(remoteDnsPort, localDnsPort int, dnsOrder []string, ttl int64) error

func WithEscape

func WithEscape(add, remove string) dnsResolveOpt

func WithResolveConf

func WithResolveConf(resolve string) dnsResolveOpt

func WriteCache

func WriteCache(domain string, qtype uint16, answer []dns.RR, timestamp int64)

WriteCache record to cache

Types

type DnsServer

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

func (*DnsServer) ServeDNS

func (s *DnsServer) ServeDNS(w dns.ResponseWriter, req *dns.Msg)

ServeDNS query DNS record

type DomainNotExistError

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

DomainNotExistError ...

func (DomainNotExistError) Error

func (e DomainNotExistError) Error() string

type IDns

type IDns interface {
	Server(context.Context) error
}

func NewDnsServer

func NewDnsServer(a arecord, rtr rtrrecord, port int) IDns

type NsEntry

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