server

package
v2.11.2+incompatible Latest Latest
Warning

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

Go to latest
Published: Dec 21, 2016 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DefaultTTL       = uint32(3600)
	CleanupInterval  = time.Second * 120
	CleanupThreshold = 512
)
View Source
const (
	QueryTimeout = time.Second * 8
)

Variables

This section is empty.

Functions

This section is empty.

Types

type ARecord

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

type CacheServer

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

func NewCacheServer

func NewCacheServer(space app.Space, config *dns.Config) *CacheServer

func (*CacheServer) Get

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

func (*CacheServer) GetCached

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

Private: Visible for testing.

func (*CacheServer) Release

func (v *CacheServer) Release()

type CacheServerFactory

type CacheServerFactory struct{}

func (CacheServerFactory) AppId

func (v CacheServerFactory) AppId() app.ID

func (CacheServerFactory) Create

func (v CacheServerFactory) Create(space app.Space, config interface{}) (app.Application, error)

type DomainRecord

type DomainRecord struct {
	A *ARecord
}

type LocalNameServer

type LocalNameServer struct {
}

func (*LocalNameServer) QueryA

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

type NameServer

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

type PendingRequest

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

type UDPNameServer

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

func NewUDPNameServer

func NewUDPNameServer(address v2net.Destination, dispatcher dispatcher.PacketDispatcher) *UDPNameServer

func (*UDPNameServer) AssignUnusedID

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

Private: Visible for testing.

func (*UDPNameServer) BuildQueryA

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

func (*UDPNameServer) Cleanup

func (v *UDPNameServer) Cleanup()

Private: Visible for testing.

func (*UDPNameServer) DispatchQuery

func (v *UDPNameServer) DispatchQuery(payload *buf.Buffer)

func (*UDPNameServer) HandleResponse

func (v *UDPNameServer) HandleResponse(dest v2net.Destination, payload *buf.Buffer)

Private: Visible for testing.

func (*UDPNameServer) QueryA

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

Jump to

Keyboard shortcuts

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