server

package

v2.51.1+incompatible Latest Latest Go to latest Published: Nov 25, 2017 License: MIT Imports: 14 Imported by: 0

Details

View Source

const (
	CleanupInterval  = time.Second * 120
	CleanupThreshold = 512
)

View Source

const (
	QueryTimeout = time.Second * 8
)

This section is empty.

This section is empty.

type ARecord struct {
	IPs    []net.IP
	Expire time.Time
}

type CacheServer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewCacheServer(ctx context.Context, config *dns.Config) (*CacheServer, error)

func (*CacheServer) Close()

func (s *CacheServer) Get(domain string) []net.IP

func (s *CacheServer) GetCached(domain string) []net.IP

func (*CacheServer) Interface() interface{}

func (*CacheServer) Start() error

type DomainRecord struct {
	IP         []net.IP
	Expire     time.Time
	LastAccess time.Time
}

func (r *DomainRecord) Expired() bool

func (r *DomainRecord) Inactive() bool

type LocalNameServer struct {
}

func (*LocalNameServer) QueryA(domain string) <-chan *ARecord

type NameServer interface {
	QueryA(domain string) <-chan *ARecord
}

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

type UDPNameServer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewUDPNameServer(address net.Destination, dispatcher dispatcher.Interface) *UDPNameServer

func (s *UDPNameServer) AssignUnusedID(response chan<- *ARecord) uint16

func (s *UDPNameServer) BuildQueryA(domain string, id uint16) *buf.Buffer

func (s *UDPNameServer) Cleanup()

func (s *UDPNameServer) HandleResponse(payload *buf.Buffer)

func (s *UDPNameServer) QueryA(domain string) <-chan *ARecord