dns

Documentation

Index

• Constants
• type DNSResolver
  • func NewDNSResolver(adsCache *ads.AdsCache) (*DNSResolver, error)
  • func (r *DNSResolver) GetAllCachedDomains() []string
  • func (r *DNSResolver) GetDNSAddresses(domain string) []string
  • func (r *DNSResolver) Query(req *dns.Msg) *dns.Msg
  • func (r *DNSResolver) StartDNSResolver(stopCh <-chan struct{})

Constants

const (
	MaxConcurrency    uint32 = 5
	RetryAfter               = 5 * time.Millisecond
	DeRefreshInterval        = 15 * time.Second
)

Types

type DNSResolver

type DNSResolver struct {
	DnsResolverChan chan []*clusterv3.Cluster

	sync.RWMutex
	// contains filtered or unexported fields
}

func NewDNSResolver

func NewDNSResolver(adsCache *ads.AdsCache) (*DNSResolver, error)

func (*DNSResolver) GetAllCachedDomains

func (r *DNSResolver) GetAllCachedDomains() []string

func (*DNSResolver) GetDNSAddresses

func (r *DNSResolver) GetDNSAddresses(domain string) []string

func (*DNSResolver) Query

func (r *DNSResolver) Query(req *dns.Msg) *dns.Msg

Query is copied and adapted from github.com/istio/istio/pilot/pkg/model/network.go.

func (*DNSResolver) StartDNSResolver

func (r *DNSResolver) StartDNSResolver(stopCh <-chan struct{})