dnscache

package module
v0.0.0-...-c70c1f2 Latest Latest
Warning

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

Go to latest
Published: Jul 20, 2013 License: MIT Imports: 3 Imported by: 52

README

A DNS cache for Go

CGO is used to lookup domain names. Given enough concurrent requests and the slightest hiccup in name resolution, it's quite easy to end up with blocked/leaking goroutines.

The issue is documented at https://code.google.com/p/go/issues/detail?id=5625

The Go team's singleflight solution (which isn't in stable yet) is rather elegant. However, it only eliminates concurrent lookups (thundering herd problems). Many systems can live with slightly stale resolve names, which means we can cacne DNS lookups and refresh them in the background.

Installation

Install using the "go get" command:

go get github.com/viki-org/dnscache

Usage

The cache is thread safe. Create a new instance by specifying how long each entry should be cached (in seconds). Items will be refreshed in the background.

//refresh items every 5 minutes
resolver := dnscache.New(time.Minute * 5)

//get an array of net.IP
ips, _ := resolver.Fetch("api.viki.io")

//get the first net.IP
ip, _ := resolver.FetchOne("api.viki.io")

//get the first net.IP as string
ip, _ := resolver.FetchOneString("api.viki.io")

If you are using an http.Transport, you can use this cache by speficifying a Dial function:

transport := &http.Transport {
  MaxIdleConnsPerHost: 64,
  Dial: func(network string, address string) (net.Conn, error) {
    separator := strings.LastIndex(address, ":")
    ip, _ := dnscache.FetchString(address[:separator])
    return net.Dial("tcp", ip + address[separator:])
  },
}

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Resolver

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

func New

func New(refreshRate time.Duration) *Resolver

func (*Resolver) Fetch

func (r *Resolver) Fetch(address string) ([]net.IP, error)

func (*Resolver) FetchOne

func (r *Resolver) FetchOne(address string) (net.IP, error)

func (*Resolver) FetchOneString

func (r *Resolver) FetchOneString(address string) (string, error)

func (*Resolver) Lookup

func (r *Resolver) Lookup(address string) ([]net.IP, error)

func (*Resolver) Refresh

func (r *Resolver) Refresh()

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL