client

Jan 16, 2024

Changes in this version

+ var DefaultWorkerPoolSize = runtime.NumCPU()

+ type Worker interface

+ Cancel func(error) bool

+ Shutdown func(context.Context) error

+ Start func(context.Context) error

+ type WorkerPool struct

+ func NewWorkerPool(c Client, maxWorkers int) (*WorkerPool, error)

+ func (wp *WorkerPool) Cancel(reason error) bool

+ func (wp *WorkerPool) Cancelled() <-chan struct{}

+ func (wp *WorkerPool) Done() <-chan struct{}

+ func (wp *WorkerPool) ExchangeContext(ctx context.Context, req *dns.Msg, server string) (*dns.Msg, time.Duration, error)

+ func (wp *WorkerPool) IsCancelled() bool

+ func (wp *WorkerPool) OnShutdown(fn func(error))

+ func (wp *WorkerPool) Shutdown(ctx context.Context) error

+ func (wp *WorkerPool) Start(ctx context.Context) error

+ func (wp *WorkerPool) Unwrap() *dns.Client

+ func (wp *WorkerPool) Wait() error

Dec 15, 2023

Changes in this version

+ type NoAAAA struct

+ func NewNoAAAA(c Client) *NoAAAA

+ func (c NoAAAA) ExchangeContext(ctx context.Context, req *dns.Msg, server string) (*dns.Msg, time.Duration, error)

+ func (c NoAAAA) Unwrap() *dns.Client

Dec 14, 2023

Changes in this version

+ func HasIPv6Support() bool

Dec 13, 2023

Changes in this version

+ type Auto struct

+ TCP Client

+ TLS Client

+ UDP Client

+ func NewAutoClient(udp, tcp Client, exp time.Duration) (*Auto, error)

+ func (c *Auto) ExchangeContext(ctx context.Context, req *dns.Msg, server string) (*dns.Msg, time.Duration, error)

+ func (c *Auto) SetDefaults() error

Dec 12, 2023

Changes in this version

+ func Unwrap(c Client) *dns.Client

+ type ExchangeFunc func(context.Context, *dns.Msg, string) (*dns.Msg, time.Duration, error)

+ func (fn ExchangeFunc) ExchangeContext(ctx context.Context, req *dns.Msg, server string) (*dns.Msg, time.Duration, error)

type SingleFlight

+ func (sfc *SingleFlight) Unwrap() *dns.Client

+ type Unwrapper interface

+ Unwrap func() *dns.Client

Dec 6, 2023

Changes in this version

+ const DefaultSingleFlightExpiration

+ type Client interface

+ ExchangeContext func(context.Context, *dns.Msg, string) (*dns.Msg, time.Duration, error)

+ func NewDefaultClient() Client

+ type SingleFlight struct

+ func NewSingleFlight(c Client, exp time.Duration) *SingleFlight

+ func (*SingleFlight) RequestKey(req *dns.Msg, server string) string

+ func (sfc *SingleFlight) ExchangeContext(ctx context.Context, req *dns.Msg, server string) (*dns.Msg, time.Duration, error)