dns

Documentation

Index

• Constants
• Variables
• type Cache
  • func New(ttl time.Duration, opts ...CacheOption) *Cache
  • func (c *Cache) Delete(ctx context.Context, host string) error
  • func (c *Cache) Get(ctx context.Context, host string) (IPCache, error)
  • func (c *Cache) GetDialContext(retryDialIfCacheFail ...bool) func(context.Context, string, string) (net.Conn, error)
  • func (c *Cache) Lookup(ctx context.Context, host string) ([]net.IP, error)
  • func (c *Cache) LookupWithCache(ctx context.Context, host string) ([]net.IP, error)
  • func (c *Cache) Set(ctx context.Context, host string, ipCache IPCache) error
• type CacheOption
  • func DialerOption(dialer *net.Dialer) CacheOption
  • func NetworkOption(network int) CacheOption
  • func OnStatsOption(onStats OnStats) CacheOption
  • func PolicyOption(policy int) CacheOption
  • func ResolverOption(resolver *net.Resolver) CacheOption
  • func StaleOption(stale time.Duration) CacheOption
  • func StorageOption(storage Storage) CacheOption
  • func TimeoutOption(value time.Duration) CacheOption
• type IPCache
• type OnStats
• type Storage

Constants

const (
	PolicyFirst = iota
	PolicyRandom
	PolicyRoundRobin
)

const (
	NetworkIP = iota
	NetworkIPV4
	NetworkIPV6
)

Variables

var ErrNotFound = errors.New("Not Found")

Types

type Cache

type Cache struct {
	Storage  Storage
	TTL      time.Duration
	Stale    time.Duration
	OnStats  OnStats
	Dialer   *net.Dialer
	Resolver *net.Resolver
	Policy   int
	Network  int
	Timeout  time.Duration
	// contains filtered or unexported fields
}

Cache dns cache

func New

func New(ttl time.Duration, opts ...CacheOption) *Cache

New create a dns cache instance

func (*Cache) Delete

func (c *Cache) Delete(ctx context.Context, host string) error

Removes cache of host

func (*Cache) Get

func (c *Cache) Get(ctx context.Context, host string) (IPCache, error)

Gets ip cache of host

func (*Cache) GetDialContext

func (c *Cache) GetDialContext(retryDialIfCacheFail ...bool) func(context.Context, string, string) (net.Conn, error)

GetDialContext get dial context function with cache

func (*Cache) Lookup

func (c *Cache) Lookup(ctx context.Context, host string) ([]net.IP, error)

Lookup lookup

func (*Cache) LookupWithCache

func (c *Cache) LookupWithCache(ctx context.Context, host string) ([]net.IP, error)

LookupWithCache lookup with cache

func (*Cache) Set

func (c *Cache) Set(ctx context.Context, host string, ipCache IPCache) error

Sets ip cache for the host

type CacheOption

type CacheOption func(*Cache)

func DialerOption

func DialerOption(dialer *net.Dialer) CacheOption

DialerOption sets dialer

func NetworkOption

func NetworkOption(network int) CacheOption

NetworkOption set network option

func OnStatsOption

func OnStatsOption(onStats OnStats) CacheOption

OnStatsOption sets on stats function

func PolicyOption

func PolicyOption(policy int) CacheOption

PolicyOption sets policy

func ResolverOption

func ResolverOption(resolver *net.Resolver) CacheOption

ResolverOption sets resolver

func StaleOption

func StaleOption(stale time.Duration) CacheOption

StaleOption sets stale

func StorageOption

func StorageOption(storage Storage) CacheOption

StorageOption sets storage

func TimeoutOption

func TimeoutOption(value time.Duration) CacheOption

TimeoutOption set timeout option

type IPCache

type IPCache struct {
	IPAddrs   []net.IP
	CreatedAt time.Time
}

IPCache ip cache

type OnStats

type OnStats func(host string, d time.Duration, ipAddrs []string)

OnStats on stats function

type Storage

type Storage interface {
	Set(ctx context.Context, host string, ipCache IPCache, ttl time.Duration) error
	Delete(ctx context.Context, host string) error
	Get(ctx context.Context, host string) (IPCache, error)
}